#1088 fix issue insert

CityofToronto · Dec 6, 2024 · e0f678b · e0f678b
1 parent 1eed832
commit e0f678b
Show file tree

Hide file tree

Showing 4 changed files with 5 additions and 5 deletions.
diff --git a/dags/rodars_pull.py b/dags/rodars_pull.py
@@ -30,7 +30,7 @@
     'retries': 1,
     'retry_delay': timedelta(minutes=5),
     'retry_exponential_backoff': True, #Allow for progressive longer waits between retries
-    'on_failure_callback': partial(task_fail_slack_alert, use_proxy = True),
+    #'on_failure_callback': partial(task_fail_slack_alert, use_proxy = True),
     'catchup': True,
 }
 

diff --git a/events/construction/itsc_issues_functions.py b/events/construction/itsc_issues_functions.py
@@ -43,7 +43,7 @@ def geometry_from_bytes(geo_bytes):
             coordinates_list.append(coordinates)
         return coordinates_list
 
-def process_row_lanesaffected(json_str):
+def process_lanesaffected(json_str):
     if (json_str == 'Unknown') | (json_str is None):
         return None
     lanesaffected = json.loads(json_str)

diff --git a/events/construction/sql/insert-itsc_issues.sql b/events/construction/sql/insert-itsc_issues.sql
@@ -8,7 +8,7 @@ INSERT INTO congestion_events.itsc_issues (
     updateremindernoticeseconds
 )
 VALUES %s
-ON CONFLICT (divisionid, issueid, locationindex)
+ON CONFLICT (divisionid, issueid)
 DO UPDATE SET
 divisionname = excluded.divisionname,
 timestamputc = excluded.timestamputc,

diff --git a/events/construction/sql/select-itsc_issues.sql b/events/construction/sql/select-itsc_issues.sql
@@ -19,8 +19,8 @@ WITH issues AS (
             8014, --rodars (old)
             8023 --TMMS TM3 Planned Work
         )
-        AND timestamputc >= {start}::date -- noqa: PRS
-        AND timestamputc < {start}::date + interval '1 day' -- noqa: PRS
+        --AND timestamputc >= {start}::date -- noqa: PRS
+        --AND timestamputc < {start}::date + interval '1 day' -- noqa: PRS
     ORDER BY divisionid ASC, issueid ASC, timestamputc DESC
 )