apache_beam.portability.api.org.apache.beam.model.fn_execution.v1.beam_provision_api_pb2_grpc module

Client and server classes corresponding to protobuf-defined services.

class apache_beam.portability.api.org.apache.beam.model.fn_execution.v1.beam_provision_api_pb2_grpc.ProvisionServiceStub(channel)

Bases: object

A service to provide runtime provisioning information to the SDK harness worker instances – such as pipeline options, resource constraints and other job metadata – needed by an SDK harness instance to initialize.

Constructor.

Parameters:

channel – A grpc.Channel.

class apache_beam.portability.api.org.apache.beam.model.fn_execution.v1.beam_provision_api_pb2_grpc.ProvisionServiceServicer

Bases: object

A service to provide runtime provisioning information to the SDK harness worker instances – such as pipeline options, resource constraints and other job metadata – needed by an SDK harness instance to initialize.

GetProvisionInfo(request, context)

Get provision information for the SDK harness worker instance.

apache_beam.portability.api.org.apache.beam.model.fn_execution.v1.beam_provision_api_pb2_grpc.add_ProvisionServiceServicer_to_server(servicer, server)

class apache_beam.portability.api.org.apache.beam.model.fn_execution.v1.beam_provision_api_pb2_grpc.ProvisionService

Bases: object

A service to provide runtime provisioning information to the SDK harness worker instances – such as pipeline options, resource constraints and other job metadata – needed by an SDK harness instance to initialize.

static GetProvisionInfo(request, target, options=(), channel_credentials=None, call_credentials=None, insecure=False, compression=None, wait_for_ready=None, timeout=None, metadata=None)