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

GetJobs(request, context)

Get a list of all invoked jobs

GetState(request, context)

Get the current state of the job

GetPipeline(request, context)

Get the job’s pipeline

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

GetJobMetrics(request, context)

Fetch metrics for a given job

DescribePipelineOptions(request, context)

Get the supported pipeline options of the runner

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