From 09a5391f8d22f50ee63d439b4652533999e4017c Mon Sep 17 00:00:00 2001 From: sarafonseca Date: Wed, 21 Feb 2024 13:40:40 -0300 Subject: [PATCH] Fix typo on DataflowStartFlexTemplateOperator documentation (#37595) --- airflow/providers/google/cloud/operators/dataflow.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/airflow/providers/google/cloud/operators/dataflow.py b/airflow/providers/google/cloud/operators/dataflow.py index 79070cfac8ae0b..cdc1bca65a457c 100644 --- a/airflow/providers/google/cloud/operators/dataflow.py +++ b/airflow/providers/google/cloud/operators/dataflow.py @@ -784,10 +784,10 @@ class DataflowStartFlexTemplateOperator(GoogleCloudBaseOperator): pipeline code, step two will not start until the process stops. When this process stops, steps two will run, but it will only execute one iteration as the job will be in a terminal state. - If you in your pipeline do not call the wait_for_pipeline method but pass wait_until_finish=True + If you in your pipeline do not call the wait_for_pipeline method but pass wait_until_finished=True to the operator, the second loop will wait for the job's terminal state. - If you in your pipeline do not call the wait_for_pipeline method, and pass wait_until_finish=False + If you in your pipeline do not call the wait_for_pipeline method, and pass wait_until_finished=False to the operator, the second loop will check once is job not in terminal state and exit the loop. :param impersonation_chain: Optional service account to impersonate using short-term credentials, or chained list of accounts required to get the access_token