tff.framework.ExecutorService

A wrapper around a target executor that makes it into a gRPC service.

tff.framework.ExecutorService(
    executor, *args, **kwargs
)

Methods

Compute(
    request: executor_pb2.ComputeRequest,
    context: grpc.ServicerContext
) -> executor_pb2.ComputeResponse

Computes a value embedded in the executor.

CreateCall(
    request: executor_pb2.CreateCallRequest,
    context: grpc.ServicerContext
) -> executor_pb2.CreateCallResponse

Creates a call embedded in the executor.

CreateSelection(
    request: executor_pb2.CreateSelectionRequest,
    context: grpc.ServicerContext
) -> executor_pb2.CreateSelectionResponse

Creates a selection embedded in the executor.

CreateTuple(
    request: executor_pb2.CreateTupleRequest,
    context: grpc.ServicerContext
) -> executor_pb2.CreateTupleResponse

Creates a tuple embedded in the executor.

CreateValue(
    request: executor_pb2.CreateValueRequest,
    context: grpc.ServicerContext
) -> executor_pb2.CreateValueResponse

Creates a value embedded in the executor.

Dispose(
    request: executor_pb2.DisposeRequest,
    context: grpc.ServicerContext
) -> executor_pb2.DisposeResponse

Disposes of a value, making it no longer available for future calls.

Execute(
    request_iter: Iterable[executor_pb2.ExecuteRequest],
    context: grpc.ServicerContext
) -> Iterable[executor_pb2.ExecuteResponse]

Yields responses to streaming requests.