Merge pull request #39 from EcoDataFlow/feature/generation

Feature/generation
EcoDataFlow · Jan 12, 2024 · 8f4413e · 8f4413e
2 parents 95f1e80 + 4eb7737
commit 8f4413e
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/dags/energy/generation/solar_energy_generation_elt.py b/dags/energy/generation/solar_energy_generation_elt.py
@@ -12,7 +12,7 @@
 
 
 dag = DAG(
-    dag_id="bigquery_elt_dag",
+    dag_id="solar_energy_generation_elt",
     default_args=default_args,
     description="bigquery_to_bigquery",
     schedule_interval="@daily",

diff --git a/dags/energy/generation/solar_energy_generation_et.py b/dags/energy/generation/solar_energy_generation_et.py
@@ -127,7 +127,7 @@ def csv_transform_datetime(**kwargs):
 
 
 dag = DAG(
-    dag_id="api_data_extract",
+    dag_id="solar_energy_generation_et",
     default_args=default_args,
     description="api_data_extract",
     schedule_interval="@daily",

diff --git a/dags/energy/generation/solar_energy_generation_l.py b/dags/energy/generation/solar_energy_generation_l.py
@@ -63,7 +63,7 @@ def to_bigquery(**kwargs):
 
 
 dag = DAG(
-    dag_id="api_gcs_to_bigquery",
+    dag_id="solar_energy_generation_l",
     default_args=default_args,
     description="api_data_to_gcs",
     schedule_interval="@daily",