apache_beam.runners.dataflow.dataflow_job_service module¶

class apache_beam.runners.dataflow.dataflow_job_service.DataflowBeamJob(job_id: str, pipeline, options, provision_info: apache_beam.runners.portability.fn_api_runner.fn_runner.ExtendedProvisionInfo, artifact_staging_endpoint: Optional[org.apache.beam.model.pipeline.v1.endpoints_pb2.ApiServiceDescriptor], artifact_service: apache_beam.runners.portability.artifact_service.ArtifactStagingService)[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]¶