WorkflowExecutionSensor

Google

Checks state of an execution for the given workflow_id and execution_id.

View on GitHub

Last Updated: Jan. 28, 2021

Access Instructions

Install the Google provider package into your Airflow environment.

Import the module into your DAG file and instantiate it with your desired params.

Parameters

workflow_idRequiredstrRequired. The ID of the workflow.
execution_idRequiredstrRequired. The ID of the execution.
project_idRequiredstrRequired. The ID of the Google Cloud project the cluster belongs to.
locationRequiredstrRequired. The Cloud Dataproc region in which to handle the request.
success_statesList[Execution.State]Execution states to be considered as successful, by default it’s only SUCCEEDED state
failure_statesList[Execution.State]Execution states to be considered as failures, by default they are FAILED and CANCELLED states.
retrygoogle.api_core.retry.RetryA retry object used to retry requests. If None is specified, requests will not be retried.
request_timeoutfloatThe amount of time, in seconds, to wait for the request to complete. Note that if retry is specified, the timeout applies to each individual attempt.
metadataSequence[Tuple[str, str]]Additional metadata that is provided to the method.

Documentation

Checks state of an execution for the given workflow_id and execution_id.

Was this page helpful?