Fix SNOWFLAKE_CONN_ID and DAG_ID in Snowpark system tests (apache#42952)

aws-mwaa · Oct 12, 2024 · db9c130 · db9c130
1 parent b9b24f4
commit db9c130
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/providers/tests/system/snowflake/example_snowpark_decorator.py b/providers/tests/system/snowflake/example_snowpark_decorator.py
@@ -30,8 +30,8 @@
 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
@@ -30,8 +30,8 @@
 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,