apache_beam.portability.api.beam_job_api_pb2_grpc module

class apache_beam.portability.api.beam_job_api_pb2_grpc.JobServiceStub(channel)[source]

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[source]

Bases: future.types.newobject.newobject

Job Service for running RunnerAPI pipelines

Prepare(request, context)[source]

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)[source]

Submit the job for execution

GetJobs(request, context)[source]

Get a list of all invoked jobs

GetState(request, context)[source]

Get the current state of the job

GetPipeline(request, context)[source]

Get the job’s pipeline

Cancel(request, context)[source]

Cancel the job

GetStateStream(request, context)[source]

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)[source]

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

GetJobMetrics(request, context)[source]

Fetch metrics for a given job

DescribePipelineOptions(request, context)[source]

Get the supported pipeline options of the runner

apache_beam.portability.api.beam_job_api_pb2_grpc.add_JobServiceServicer_to_server(servicer, server)[source]