fix the path

goitacademy · Jan 31, 2025 · 4c3686b · 4c3686b
1 parent 3620f8b
commit 4c3686b
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/kari/project_solution.py b/kari/project_solution.py
@@ -19,7 +19,7 @@
 # 1. landing_to_bronze.py
 landing_to_bronze = SparkSubmitOperator(
     task_id="landing_to_bronze",  
-    application="kari/landing_to_bronze.py",  
+    application="/opt/airflow/dags/airflow_sandbox/kari/landing_to_bronze.py",  
     conn_id="spark-default", 
     verbose=1,  
     dag=dag,
@@ -28,7 +28,7 @@
 # 2. bronze_to_silver.py
 bronze_to_silver = SparkSubmitOperator(
     task_id="bronze_to_silver",
-    application="kari/bronze_to_silver.py", 
+    application="/opt/airflow/dags/airflow_sandbox/kari/bronze_to_silver.py", 
     conn_id="spark-default", 
     verbose=1,  
     dag=dag,
@@ -37,7 +37,7 @@
 # 3. silver_to_gold.py
 silver_to_gold = SparkSubmitOperator(
     task_id="silver_to_gold", 
-    application="kari/silver_to_gold.py",  
+    application="/opt/airflow/dags/airflow_sandbox/kari/silver_to_gold.py",  
     verbose=1,  
     dag=dag,
 )