apache_beam.portability.api.beam_job_api_pb2_grpc module

class apache_beam.portability.api.beam_job_api_pb2_grpc.JobServiceStub(channel)

Bases: future.types.newobject.newobject

Job Service for running RunnerAPI pipelines

Constructor.

Parameters:channel – A grpc.Channel.

class apache_beam.portability.api.beam_job_api_pb2_grpc.JobServiceServicer

Bases: future.types.newobject.newobject

Job Service for running RunnerAPI pipelines

Prepare(request, context)

Prepare a job for execution. The job will not be executed until a call is made to run with the returned preparationId.

Run(request, context)

Submit the job for execution

GetState(request, context)

Get the current state of the job

Cancel(request, context)

Cancel the job

GetStateStream(request, context)

Subscribe to a stream of state changes of the job, will immediately return the current state of the job as the first response.

GetMessageStream(request, context)

Subscribe to a stream of state changes and messages from the job

apache_beam.portability.api.beam_job_api_pb2_grpc.add_JobServiceServicer_to_server(servicer, server)