This is an automated email from the ASF dual-hosted git repository.
eladkal 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 db9c130a5c Fix SNOWFLAKE_CONN_ID and DAG_ID in Snowpark system tests
(#42952)
db9c130a5c is described below
commit db9c130a5c987a12ee0f1dba624275c5844c226c
Author: Jianzhun Du <[email protected]>
AuthorDate: Fri Oct 11 17:41:32 2024 -0700
Fix SNOWFLAKE_CONN_ID and DAG_ID in Snowpark system tests (#42952)
---
providers/tests/system/snowflake/example_snowpark_decorator.py | 4 ++--
providers/tests/system/snowflake/example_snowpark_operator.py | 4 ++--
2 files changed, 4 insertions(+), 4 deletions(-)
diff --git a/providers/tests/system/snowflake/example_snowpark_decorator.py
b/providers/tests/system/snowflake/example_snowpark_decorator.py
index 3f74b97d0f..4c2319a91b 100644
--- a/providers/tests/system/snowflake/example_snowpark_decorator.py
+++ b/providers/tests/system/snowflake/example_snowpark_decorator.py
@@ -30,8 +30,8 @@ if TYPE_CHECKING:
from airflow import DAG
from airflow.decorators import task
-SNOWFLAKE_CONN_ID = "snowflake_default"
-DAG_ID = "example_snowpark"
+SNOWFLAKE_CONN_ID = "my_snowflake_conn"
+DAG_ID = "example_snowpark_decorator"
with DAG(
DAG_ID,
diff --git a/providers/tests/system/snowflake/example_snowpark_operator.py
b/providers/tests/system/snowflake/example_snowpark_operator.py
index 0543596ec9..1d7cce34f7 100644
--- a/providers/tests/system/snowflake/example_snowpark_operator.py
+++ b/providers/tests/system/snowflake/example_snowpark_operator.py
@@ -30,8 +30,8 @@ if TYPE_CHECKING:
from airflow import DAG
from airflow.providers.snowflake.operators.snowpark import SnowparkOperator
-SNOWFLAKE_CONN_ID = "snowflake_default"
-DAG_ID = "example_snowpark"
+SNOWFLAKE_CONN_ID = "my_snowflake_conn"
+DAG_ID = "example_snowpark_operator"
with DAG(
DAG_ID,
