Update ride queries to use 'system_status' instead of 'status' for co…

…nsistency
carrismetropolitana · Feb 5, 2025 · 47401aa · 47401aa
1 parent 8a77032
commit 47401aa
Show file tree

Hide file tree

Showing 4 changed files with 4 additions and 4 deletions.
diff --git a/apps/sync-metrics/src/tasks/videowall-delays.ts b/apps/sync-metrics/src/tasks/videowall-delays.ts
@@ -60,7 +60,7 @@ export const videowallDelays = async () => {
 	// (start_time_observed !== null) and that have already been processed.
 
 	const ridesCollection = await rides.getCollection();
-	const allRidesForTodayStream = ridesCollection.find({ operational_date: operationalDate, status: 'complete' }).stream();
+	const allRidesForTodayStream = ridesCollection.find({ operational_date: operationalDate, system_status: 'complete' }).stream();
 
 	//
 	// Iterate on all rides for today

diff --git a/apps/sync-metrics/src/tasks/videowall-empty-rides.ts b/apps/sync-metrics/src/tasks/videowall-empty-rides.ts
@@ -54,7 +54,7 @@ export const videowallEmptyRides = async () => {
 	// Get all rides for today
 
 	const ridesCollection = await rides.getCollection();
-	const allRidesForTodayStream = ridesCollection.find({ operational_date: operationalDate, status: 'complete' }).stream();
+	const allRidesForTodayStream = ridesCollection.find({ operational_date: operationalDate, system_status: 'complete' }).stream();
 
 	//
 	// Iterate on all rides for today

diff --git a/apps/sync-metrics/src/tasks/videowall-sla.ts b/apps/sync-metrics/src/tasks/videowall-sla.ts
@@ -64,7 +64,7 @@ export const videowallSla = async () => {
 	// Get all rides for today
 
 	const ridesCollection = await rides.getCollection();
-	const allRidesForTodayStream = ridesCollection.find({ operational_date: operationalDate, status: 'complete' }).stream();
+	const allRidesForTodayStream = ridesCollection.find({ operational_date: operationalDate, system_status: 'complete' }).stream();
 
 	//
 	// Iterate on all rides for today

diff --git a/apps/sync-metrics/src/tasks/videowall-vkm.ts b/apps/sync-metrics/src/tasks/videowall-vkm.ts
@@ -64,7 +64,7 @@ export const videowallVkm = async () => {
 	// Get all rides for today
 
 	const ridesCollection = await rides.getCollection();
-	const allRidesForTodayStream = ridesCollection.find({ operational_date: operationalDate, status: 'complete' }).stream();
+	const allRidesForTodayStream = ridesCollection.find({ operational_date: operationalDate, system_status: 'complete' }).stream();
 
 	//
 	// Iterate on all rides for today