apache_beam.portability.api.org.apache.beam.model.job_management.v1.beam_job_api_pb2_grpc module¶
Client and server classes corresponding to protobuf-defined services.
-
class
apache_beam.portability.api.org.apache.beam.model.job_management.v1.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.org.apache.beam.model.job_management.v1.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.
-
-
apache_beam.portability.api.org.apache.beam.model.job_management.v1.beam_job_api_pb2_grpc.
add_JobServiceServicer_to_server
(servicer, server)[source]¶
-
class
apache_beam.portability.api.org.apache.beam.model.job_management.v1.beam_job_api_pb2_grpc.
JobService
[source]¶ Bases:
object
Job Service for running RunnerAPI pipelines
-
static
Prepare
(request, target, options=(), channel_credentials=None, call_credentials=None, insecure=False, compression=None, wait_for_ready=None, timeout=None, metadata=None)[source]¶
-
static
Run
(request, target, options=(), channel_credentials=None, call_credentials=None, insecure=False, compression=None, wait_for_ready=None, timeout=None, metadata=None)[source]¶
-
static
GetJobs
(request, target, options=(), channel_credentials=None, call_credentials=None, insecure=False, compression=None, wait_for_ready=None, timeout=None, metadata=None)[source]¶
-
static
GetState
(request, target, options=(), channel_credentials=None, call_credentials=None, insecure=False, compression=None, wait_for_ready=None, timeout=None, metadata=None)[source]¶
-
static
GetPipeline
(request, target, options=(), channel_credentials=None, call_credentials=None, insecure=False, compression=None, wait_for_ready=None, timeout=None, metadata=None)[source]¶
-
static
Cancel
(request, target, options=(), channel_credentials=None, call_credentials=None, insecure=False, compression=None, wait_for_ready=None, timeout=None, metadata=None)[source]¶
-
static
Drain
(request, target, options=(), channel_credentials=None, call_credentials=None, insecure=False, compression=None, wait_for_ready=None, timeout=None, metadata=None)[source]¶
-
static
GetStateStream
(request, target, options=(), channel_credentials=None, call_credentials=None, insecure=False, compression=None, wait_for_ready=None, timeout=None, metadata=None)[source]¶
-
static
GetMessageStream
(request, target, options=(), channel_credentials=None, call_credentials=None, insecure=False, compression=None, wait_for_ready=None, timeout=None, metadata=None)[source]¶
-
static