apache_beam.portability.api.beam_provision_api_pb2_grpc module¶

class apache_beam.portability.api.beam_provision_api_pb2_grpc.ProvisionServiceStub(channel)[source]¶

Bases: future.types.newobject.newobject

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.beam_provision_api_pb2_grpc.ProvisionServiceServicer[source]¶

Bases: future.types.newobject.newobject

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)[source]¶: Get provision information for the SDK harness worker instance.

apache_beam.portability.api.beam_provision_api_pb2_grpc.add_ProvisionServiceServicer_to_server(servicer, server)[source]¶