jina.serve.runtimes.asyncio module

class jina.serve.runtimes.asyncio.AsyncNewLoopRuntime(args, cancel_event=None, \*kwargs*)[source]

Bases: jina.serve.runtimes.base.BaseRuntime, abc.ABC

The async runtime to start a new event loop.

• run_forever()[source]

  Running method to block the main thread.

  Run the event loop until a Future is done.

• teardown()[source]

  Call async_teardown() and stop and close the event loop.

• async async_setup()[source]

  The async method to setup.

• async async_teardown()[source]

  The async method to clean up resources during teardown. This method should free all resources allocated during async_setup

• abstract async async_cancel()[source]

  An async method to cancel async_run_forever.

• abstract async async_run_forever()[source]

  The async method to run until it is stopped.

• static activate(\*kwargs*)[source]

  Activate the runtime, does not apply to these runtimes

  • Parameters

    kwargs – extra keyword arguments

• static is_ready(ctrl_address, \*kwargs*)[source]

  Check if status is ready.

  • Parameters

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

    • kwargs – extra keyword arguments

    Return type

    bool

    Returns

    True if status is ready else False.

• 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