apache_beam.portability.api.beam_job_api_pb2_grpc module¶
-
class
apache_beam.portability.api.beam_job_api_pb2_grpc.
JobServiceStub
(channel)[source]¶ Bases:
object
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:
object
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.
-
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.
-