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

Bases: apache_beam.portability.api.beam_job_api_pb2_grpc.JobServiceServicer

run(request, context)

getState(request, context)

cancel(request, context)

getMessageStream(request, context)

getStateStream(request, context)

apache_beam.runners.experimental.python_rpc_direct.server.serve()