jina.orchestrate.pods.jinad module#

class jina.orchestrate.pods.jinad.JinaDProcessTarget[source]#

Bases: object

Target to be executed on JinaD Process

property filepaths: List[Path]#

Get file/directories to be uploaded to remote workspace

Return type

List[Path]

Returns

filepaths to be uploaded to remote

class jina.orchestrate.pods.jinad.JinaDPod(args)[source]#

Bases: BasePod

Manages a remote Pod by handling a separate Process / Thread

static wait_for_ready_or_shutdown(timeout, ready_or_shutdown_event, ctrl_address, **kwargs)[source]#

Check if the runtime has successfully started

Parameters

  • timeout (Optional[float]) – The time to wait before readiness or failure is determined

  • ctrl_address (str) – the address where the control message needs to be sent

  • ready_or_shutdown_event (Union[Event, Event]) – the multiprocessing event to detect if the process failed or is ready

  • kwargs – extra keyword arguments

Returns

True if is ready or it needs to be shutdown

start()[source]#

Start the JinaD Process (to manage remote Pod). .. #noqa: DAR201

join(*args, **kwargs)[source]#

Joins the Pod. This method calls join() in threading.Thread or multiprocesssing.Process.

Parameters

  • args – extra positional arguments to pass to join

  • kwargs – extra keyword arguments to pass to join