apache_beam.runners.experimental.python_rpc_direct.server module

A runner implementation that submits a job for remote execution.

class apache_beam.runners.experimental.python_rpc_direct.server.JobService[source]

Bases: apache_beam.portability.api.beam_job_api_pb2_grpc.JobServiceServicer

run(request, context)[source]
getState(request, context)[source]
cancel(request, context)[source]
getMessageStream(request, context)[source]
getStateStream(request, context)[source]
apache_beam.runners.experimental.python_rpc_direct.server.serve()[source]