#1088 vds_bot -> events_bot

CityofToronto · Dec 12, 2024 · 3eb07f9 · 3eb07f9
1 parent 32e6436
commit 3eb07f9
Show file tree

Hide file tree

Showing 4 changed files with 7 additions and 7 deletions.
diff --git a/dags/rodars_pull.py b/dags/rodars_pull.py
@@ -51,15 +51,15 @@ def rodars_dag():
     def pull_rodars_issues(ds = None):
         "Get RODARS data from ITSC and insert into bigdata `congestion_events.itsc_issues`"
         itsc_bot = PostgresHook('itsc_postgres')
-        vds_bot = PostgresHook('vds_bot')
-        fetch_and_insert_issue_data(select_conn=itsc_bot, insert_conn=vds_bot, start_date=ds)
+        events_bot = PostgresHook('events_bot')
+        fetch_and_insert_issue_data(select_conn=itsc_bot, insert_conn=events_bot, start_date=ds)
 
     @task
     def pull_rodar_locations(ds = None):
         "Get RODARS data from ITSC and insert into bigdata `congestion_events.itsc_issue_locations`"
         itsc_bot = PostgresHook('itsc_postgres')
-        vds_bot = PostgresHook('vds_bot')
-        fetch_and_insert_location_data(select_conn=itsc_bot, insert_conn=vds_bot, start_date=ds)
+        events_bot = PostgresHook('events_bot')
+        fetch_and_insert_location_data(select_conn=itsc_bot, insert_conn=events_bot, start_date=ds)
     #add a delete task to remove outdated revisions?
 
     pull_rodars_issues()

diff --git a/events/construction/sql/create-function-get_lanesaffected_sum.sql b/events/construction/sql/create-function-get_lanesaffected_sum.sql
@@ -47,4 +47,4 @@ GRANT EXECUTE ON FUNCTION itsc_factors.get_lanesaffected_sums(text) TO PUBLIC;
 
 GRANT EXECUTE ON FUNCTION itsc_factors.get_lanesaffected_sums(text) TO congestion_admins;
 
-GRANT EXECUTE ON FUNCTION itsc_factors.get_lanesaffected_sums(text) TO vds_bot;
+GRANT EXECUTE ON FUNCTION itsc_factors.get_lanesaffected_sums(text) TO events_bot;
diff --git a/events/construction/sql/create_table-itsc_issues.sql b/events/construction/sql/create_table-itsc_issues.sql
@@ -44,4 +44,4 @@ GRANT ALL ON TABLE congestion_events.itsc_issues TO dbadmin;
 
 GRANT ALL ON TABLE congestion_events.itsc_issues TO rds_superuser WITH GRANT OPTION;
 
-GRANT ALL ON TABLE congestion_events.itsc_issues TO vds_bot;
+GRANT ALL ON TABLE congestion_events.itsc_issues TO events_bot;
diff --git a/events/construction/sql/create_table-itsc_issues_locations.sql b/events/construction/sql/create_table-itsc_issues_locations.sql
@@ -39,4 +39,4 @@ GRANT ALL ON TABLE congestion_events.itsc_issue_locations TO dbadmin;
 
 GRANT ALL ON TABLE congestion_events.itsc_issue_locations TO rds_superuser WITH GRANT OPTION;
 
-GRANT ALL ON TABLE congestion_events.itsc_issue_locations TO vds_bot;
+GRANT ALL ON TABLE congestion_events.itsc_issue_locations TO events_bot;
Original file line number	Diff line number	Diff line change
Expand Up		@@ -47,4 +47,4 @@ GRANT EXECUTE ON FUNCTION itsc_factors.get_lanesaffected_sums(text) TO PUBLIC;

		GRANT EXECUTE ON FUNCTION itsc_factors.get_lanesaffected_sums(text) TO congestion_admins;

		GRANT EXECUTE ON FUNCTION itsc_factors.get_lanesaffected_sums(text) TO vds_bot;
		GRANT EXECUTE ON FUNCTION itsc_factors.get_lanesaffected_sums(text) TO events_bot;
Original file line number	Diff line number	Diff line change
Expand Up		@@ -44,4 +44,4 @@ GRANT ALL ON TABLE congestion_events.itsc_issues TO dbadmin;

		GRANT ALL ON TABLE congestion_events.itsc_issues TO rds_superuser WITH GRANT OPTION;

		GRANT ALL ON TABLE congestion_events.itsc_issues TO vds_bot;
		GRANT ALL ON TABLE congestion_events.itsc_issues TO events_bot;
Original file line number	Diff line number	Diff line change
Expand Up		@@ -39,4 +39,4 @@ GRANT ALL ON TABLE congestion_events.itsc_issue_locations TO dbadmin;

		GRANT ALL ON TABLE congestion_events.itsc_issue_locations TO rds_superuser WITH GRANT OPTION;

		GRANT ALL ON TABLE congestion_events.itsc_issue_locations TO vds_bot;
		GRANT ALL ON TABLE congestion_events.itsc_issue_locations TO events_bot;