fix daily aqi jobs

anacondaf · Jan 19, 2024 · 2ef6150 · 2ef6150
1 parent 5a0006c
commit 2ef6150
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 59 deletions.
diff --git a/backend/src/jobs/definitions/getHourlyAqi.js b/backend/src/jobs/definitions/getHourlyAqi.js
diff --git a/backend/src/jobs/definitions/index.js b/backend/src/jobs/definitions/index.js
@@ -1,8 +1,7 @@
 const { retrieveDailyAqi } = require("./retrieveDailyAqi");
-const { getHourlyAqi } = require("./getHourlyAqi");
 const logger = require("../../config/logger");
 
-let definitions = [retrieveDailyAqi, getHourlyAqi];
+let definitions = [retrieveDailyAqi];
 
 const loadDefinitions = async (agenda) => {
 	try {

diff --git a/backend/src/jobs/definitions/retrieveDailyAqi.js b/backend/src/jobs/definitions/retrieveDailyAqi.js
@@ -18,6 +18,8 @@ const retrieveDailyAqi = async (agenda) => {
 						.toISOString()
 						.replace(/T(.+)/g, "T00:00:00.000Z");
 
+					logger.info(`Get AQI for ${offsetNextDay}`);
+
 					let hourlyAqi = await AirQualityModel.aggregate([
 						{
 							$addFields: {
@@ -56,7 +58,7 @@ const retrieveDailyAqi = async (agenda) => {
 						},
 					]).exec();
 
-					console.log(hourlyAqi);
+					logger.info(JSON.stringify(hourlyAqi));
 
 					hourlyAqi = hourlyAqi.map((x) => {
 						return {
@@ -65,7 +67,7 @@ const retrieveDailyAqi = async (agenda) => {
 						};
 					});
 
-					console.log(hourlyAqi);
+					logger.info(JSON.stringify(hourlyAqi));
 
 					const compositeAqiObject = hourlyAqi.reduce((prev, curr) =>
 						prev.aqi > curr.aqi ? prev : curr
@@ -76,7 +78,7 @@ const retrieveDailyAqi = async (agenda) => {
 						date: compositeAqiObject.dateTime.substring(0, 10),
 					};
 
-					console.log(requestBody);
+					logger.info(JSON.stringify(requestBody));
 
 					await axios({
 						method: "post",