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: future.types.newobject.newobject
A native co-process to start a contianer that speaks the JobApi