apache_beam.runners.dataflow.dataflow_job_service module

class apache_beam.runners.dataflow.dataflow_job_service.DataflowBeamJob(job_id: str, pipeline, options, provision_info: ExtendedProvisionInfo, artifact_staging_endpoint: ApiServiceDescriptor | None, artifact_service: ArtifactStagingService)[source]

Bases: 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]