Merge pull request #40 from EcoDataFlow/feature/generation

Feature/generation
EcoDataFlow · Jan 12, 2024 · 45cf7bb · 45cf7bb
2 parents 8f4413e + 12a4ff2
commit 45cf7bb
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
diff --git a/dags/energy/generation/solar_energy_generation_et.py b/dags/energy/generation/solar_energy_generation_et.py
@@ -157,7 +157,7 @@ def csv_transform_datetime(**kwargs):
 
 trigger_target_dag_task = TriggerDagRunOperator(
     task_id="trigger_target_dag",
-    trigger_dag_id="api_gcs_to_bigquery",  # 트리거하려는 대상 DAG의 ID
+    trigger_dag_id="solar_energy_generation_l",  # 트리거하려는 대상 DAG의 ID
     dag=dag,
 )
 

diff --git a/dags/energy/generation/solar_energy_generation_l.py b/dags/energy/generation/solar_energy_generation_l.py
@@ -8,6 +8,7 @@
 from airflow.operators.python_operator import PythonOperator
 from airflow.operators.dagrun_operator import TriggerDagRunOperator
 
+
 BUCKET_NAME = "data-lake-storage"
 
 
@@ -89,7 +90,7 @@ def to_bigquery(**kwargs):
 
 trigger_target_dag_task = TriggerDagRunOperator(
     task_id="trigger_target_dag",
-    trigger_dag_id="bigquery_elt_dag",  # 트리거하려는 대상 DAG의 ID
+    trigger_dag_id="solar_energy_generation_elt",  # 트리거하려는 대상 DAG의 ID
     dag=dag,
 )