Check for the state of batch.

View on GitHub

Last Updated: Jan. 16, 2023

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.


batch_idRequiredThe Dataproc batch ID to poll. (templated)
regionRequiredRequired. The Cloud Dataproc region in which to handle the request. (templated)
project_idThe ID of the google cloud project in which to create the cluster. (templated)
gcp_conn_idThe connection ID to use connecting to Google Cloud Platform.
wait_timeoutHow many seconds wait for job to be ready.


Check for the state of batch.

Was this page helpful?