jina.serve.runtimes.asyncio module#

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

Bases: BaseRuntime, 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