fp update8

goitacademy · Jan 29, 2025 · 875caa9 · 875caa9
1 parent 86dad6f
commit 875caa9
Show file tree

Hide file tree

Showing 6 changed files with 3 additions and 3 deletions.
diff --git a/encrypted_file/eugene_etl_pipeline.tar_encrypted.tar.gz b/encrypted_file/eugene_etl_pipeline.tar_encrypted.tar.gz
diff --git a/dags/eugene/bronze_to_silver.py → eugene/bronze_to_silver.py b/dags/eugene/bronze_to_silver.py → eugene/bronze_to_silver.py
diff --git a/eugene/eugene_etl_pipeline.tar.gz b/eugene/eugene_etl_pipeline.tar.gz
diff --git a/dags/eugene/landing_to_bronze.py → eugene/landing_to_bronze.py b/dags/eugene/landing_to_bronze.py → eugene/landing_to_bronze.py
diff --git a/dags/eugene/project_solution.py → eugene/project_solution.py b/dags/eugene/project_solution.py → eugene/project_solution.py
@@ -21,7 +21,7 @@
 
     # Landing to bronze
     landing_to_bronze_all = SparkSubmitOperator(
-        application='/root/airflow-docker/dags/landing_to_bronze.py',  # Шлях до скрипту
+        application='./landing_to_bronze.py',  # Шлях до скрипту
         task_id='landing_to_bronze_all_tables',  # Унікальний ідентифікатор завдання
         conn_id='spark-default',  # Ідентифікатор з'єднання Spark
         verbose=1, # Рівень деталізації логів
@@ -30,7 +30,7 @@
 
     # Bronze to silver
     bronze_to_silver_all = SparkSubmitOperator(
-        application='/root/airflow-docker/dags/bronze_to_silver.py',  
+        application='./bronze_to_silver.py',  
         task_id='bronze_to_silver_all_tables', 
         conn_id='spark-default', 
         verbose=1,
@@ -39,7 +39,7 @@
 
     # Silver to gold (агрегація) 
     silver_to_gold_avg_stats = SparkSubmitOperator(
-        application='/root/airflow-docker/dags/silver_to_gold.py',  
+        application='./silver_to_gold.py',  
         task_id='silver_to_gold_avg_stats', 
         conn_id='spark-default',  
         verbose=1,

diff --git a/dags/eugene/silver_to_gold.py → eugene/silver_to_gold.py b/dags/eugene/silver_to_gold.py → eugene/silver_to_gold.py