apache_beam.runners.dataflow.dataflow_job_service module

class apache_beam.runners.dataflow.dataflow_job_service.DataflowBeamJob(job_id, pipeline, options, provision_info, artifact_staging_endpoint, artifact_service)[source]

Bases: apache_beam.runners.portability.local_job_service.BeamJob

A representation of a single Beam job to be run on the Dataflow runner.

cancel()[source]
apache_beam.runners.dataflow.dataflow_job_service.run(argv, beam_job_type=<class 'apache_beam.runners.dataflow.dataflow_job_service.DataflowBeamJob'>)[source]