apache_beam.runners.job.manager module

A object to control to the Job API Co-Process

class apache_beam.runners.job.manager.DockerRPCManager(run_command=None)[source]

Bases: object

A native co-process to start a contianer that speaks the JobApi