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

Examples

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

jobId *string

The Dataflow job ID

location *string

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

drain booleanstring

Defaultfalse

Whether to drain the job instead of cancelling it

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

impersonatedServiceAccount string

The GCP service account to impersonate

pluginDefaultsRef string

Reference (ref) of the pluginDefaults to apply to this task.

projectId string

The GCP project ID

scopes array

SubTypestring

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

The GCP scopes to be used

serviceAccount string

The GCP service account

Outputs

currentState string

The current state of the job

jobId string

The job ID

NetBox

Enterprise

Enterprise NetBox tasks to create, update, and query devices, IP addresses, and sites over the NetBox API.

Infrastructure

Clickhouse

Tasks that connect to ClickHouse via JDBC to run queries and loads.

Data

Google Cloud CancelJobCertifiedCancel or drain a running Dataflow job

Google Cloud CancelJob

More Plugins in this Category

NetBox

Clickhouse

Google Cloud CancelJob
Certified
Cancel or drain a running Dataflow job