jina.orchestrate.pods.jinad module

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

Bases: object

Target to be executed on JinaD Process

• property filepaths: List[pathlib.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: jina.orchestrate.pods.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