apache_beam.runners.experimental.python_rpc_direct.python_rpc_direct_runner module

A runner implementation that submits a job for remote execution.

class apache_beam.runners.experimental.python_rpc_direct.python_rpc_direct_runner.PythonRPCDirectRunner[source]

Bases: apache_beam.runners.runner.PipelineRunner

Executes a single pipeline on the local machine inside a container.

run(pipeline)[source]

Remotely executes entire pipeline or parts reachable from node.