Toggle Light / Dark / Auto color theme

Toggle table of contents sidebar

jina.serve.runtimes.worker package

Module contents

class jina.serve.runtimes.worker.WorkerRuntime(args, **kwargs)

Bases: jina.serve.runtimes.asyncio.AsyncNewLoopRuntime, abc.ABC

Runtime procedure leveraging Grpclet for sending DataRequests

Initialize grpc and data request handling. :type args: Namespace :param args: args from CLI :param kwargs: keyword args

async async_setup()

Start the DataRequestHandler and wait for the GRPC and Monitoring servers to start

async async_run_forever()

Block until the GRPC server is terminated

async async_cancel()

Stop the GRPC server

async async_teardown()

Close the data request handler

async process_single_data(request, context)

Process the received requests and return the result as a new request

Parameters

• request (DataRequest) – the data request to process

• context – grpc context

Return type

DataRequest

Returns

the response request

async endpoint_discovery(empty, context)

Process the the call requested and return the list of Endpoints exposed by the Executor wrapped inside this Runtime

Parameters

• empty – The service expects an empty protobuf message

• context – grpc context

Return type

EndpointsProto

Returns

the response request

async process_data(requests, context)

Process the received requests and return the result as a new request

Parameters

• requests (List[DataRequest]) – the data requests to process

• context – grpc context

Return type

DataRequest

Returns

the response request

async process_control(request, *args)

Process the received control request and return the same request

Parameters

• request (ControlRequest) – the control request to process

• args – additional arguments in the grpc call, ignored

Return type

ControlRequest

Returns

the input request