This is an automated email from the ASF dual-hosted git repository.
potiuk 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 10c4c352f9 Minor fix to DataprocCreateClusterOperator operator docs.
(#36322)
10c4c352f9 is described below
commit 10c4c352f93296ff4434fffe863aa249ad3fea5c
Author: Bartosz Jankiewicz <[email protected]>
AuthorDate: Wed Dec 20 17:27:19 2023 +0100
Minor fix to DataprocCreateClusterOperator operator docs. (#36322)
* Minor fix to DataprocCreateClusterOperator operator docs.
* Update airflow/providers/google/cloud/operators/dataproc.py
---------
Co-authored-by: bjankiewicz <[email protected]>
Co-authored-by: Jarek Potiuk <[email protected]>
---
airflow/providers/google/cloud/operators/dataproc.py | 4 +---
1 file changed, 1 insertion(+), 3 deletions(-)
diff --git a/airflow/providers/google/cloud/operators/dataproc.py
b/airflow/providers/google/cloud/operators/dataproc.py
index 0e9784dfc2..ad47a9e151 100644
--- a/airflow/providers/google/cloud/operators/dataproc.py
+++ b/airflow/providers/google/cloud/operators/dataproc.py
@@ -512,9 +512,7 @@ class
DataprocCreateClusterOperator(GoogleCloudBaseOperator):
The operator will wait until the creation is successful or an error occurs
in the creation process.
- If the cluster already exists and ``use_if_exists`` is True, the operator
will:
-
- If the cluster already exists and ``use_if_exists`` is True then the
operator will:
+ If the cluster already exists and ``use_if_exists`` is True, then the
operator will:
- if cluster state is ERROR then delete it if specified and raise error
- if cluster state is CREATING wait for it and then check for ERROR state
- if cluster state is DELETING wait for it and then create new cluster
