This is an automated email from the ASF dual-hosted git repository.
taragolis pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/main by this push:
new 52d2032887 Fix typo on DataflowStartFlexTemplateOperator documentation
(#37595)
52d2032887 is described below
commit 52d20328872b68f0f80986006726f16a6dc56c45
Author: sarafonseca <[email protected]>
AuthorDate: Wed Feb 21 13:40:40 2024 -0300
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 79070cfac8..cdc1bca65a 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
