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 a799e9dcd1 Rename GCP Dataproc Spark deferrable DAG ID to be unique
(#28057)
a799e9dcd1 is described below
commit a799e9dcd121150c9c9fbbe6ba5f40da76efe5fa
Author: Bartłomiej Hirsz <[email protected]>
AuthorDate: Mon Dec 5 03:09:33 2022 +0100
Rename GCP Dataproc Spark deferrable DAG ID to be unique (#28057)
Change-Id: I0a6c9af111bbfedd170c09498b1b9ced63133d90
Co-authored-by: Bartlomiej Hirsz <[email protected]>
---
.../google/cloud/dataproc/example_dataproc_spark_deferrable.py | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/tests/system/providers/google/cloud/dataproc/example_dataproc_spark_deferrable.py
b/tests/system/providers/google/cloud/dataproc/example_dataproc_spark_deferrable.py
index 65b841a025..d3a9a0d6ef 100644
---
a/tests/system/providers/google/cloud/dataproc/example_dataproc_spark_deferrable.py
+++
b/tests/system/providers/google/cloud/dataproc/example_dataproc_spark_deferrable.py
@@ -33,7 +33,7 @@ from airflow.providers.google.cloud.operators.dataproc import
(
from airflow.utils.trigger_rule import TriggerRule
ENV_ID = os.environ.get("SYSTEM_TESTS_ENV_ID")
-DAG_ID = "dataproc_spark"
+DAG_ID = "dataproc_spark_deferrable"
PROJECT_ID = os.environ.get("SYSTEM_TESTS_GCP_PROJECT", "")
CLUSTER_NAME = f"cluster-dataproc-spark-{ENV_ID}"