Google Cloud CancelJob

Google Cloud CancelJob

Certified

Cancel or drain a running Dataflow job

Requests a transition to JOB_STATE_CANCELLED to cancel immediately, or JOB_STATE_DRAINING to allow streaming pipelines to process in-flight data before stopping.

yaml
type: io.kestra.plugin.gcp.dataflow.CancelJob

Cancel a Dataflow job.

yaml
id: cancel_dataflow_job
namespace: company.team

tasks:
  - id: cancel
    type: io.kestra.plugin.gcp.dataflow.CancelJob
    projectId: "{{ secret('GCP_PROJECT_ID') }}"
    location: us-central1
    jobId: 2026-06-25_00_00_00-123456789
    drain: false
Properties

The Dataflow job ID

The regional endpoint (e.g. us-central1)

Defaultfalse

Whether to drain the job instead of cancelling it

Draining allows in-flight data processing to finish (only applicable to streaming jobs).

The GCP service account to impersonate

The GCP project ID

SubTypestring
Default["https://www.googleapis.com/auth/cloud-platform"]

The GCP scopes to be used

The GCP service account

The current state of the job

The job ID

More Plugins in this Category

VMware (EE)
VMware
Enterprise

Tasks that automate VMware vSphere operations within Kestra workflows.

Infrastructure

33 tasks

3 blueprints

Canonical (EE)
Canonical
Enterprise

Tasks to interact with Canonical services, enabling automation and infrastructure management through API-driven workflows.

CloudInfrastructure

5 tasks