#66, #62 Update DAG task name

CityofToronto · Oct 13, 2022 · e83e277 · e83e277
1 parent a469585
commit e83e277
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/dags/generate_congestion_agg.py b/dags/generate_congestion_agg.py
@@ -101,15 +101,15 @@ def is_day_one(date_to_pull):
 
 # Task to aggregate segment level tt monthly
 aggregate_seg_monthly = PostgresOperator(sql='''select congestion.generate_network_monthly('{{ macros.datetime.date(execution_date + macros.dateutil.relativedelta.relativedelta(months=-1, day=1)) }}');''',
-                                     task_id='aggregate_monthly',
+                                     task_id='aggregate_seg_monthly',
                                      postgres_conn_id='congestion_bot',
                                      autocommit=True,
                                      retries = 0,
                                      dag=dag)
 
 # Task to aggregate centreline level tt monthly 
 aggregate_cent_monthly = PostgresOperator(sql='''select congestion.generate_centreline_monthly('{{ macros.datetime.date(execution_date + macros.dateutil.relativedelta.relativedelta(months=-1, day=1)) }}');''',
-                                     task_id='aggregate_monthly',
+                                     task_id='aggregate_cent_monthly',
                                      postgres_conn_id='congestion_bot',
                                      autocommit=True,
                                      retries = 0,