diff --git a/server/utils/scheduler.ts b/server/utils/scheduler.ts
index a06c3e4..7395fec 100644
--- a/server/utils/scheduler.ts
+++ b/server/utils/scheduler.ts
@@ -19,6 +19,7 @@ import { processQueuedEngineEvents } from "../services/notificationEngine";
 import { runEnrichmentBatch, seedEnrichmentQueue } from "./enrichmentWorker";
 import { runJobAlertJob } from "./jobAlertJob";
 import { runSponsorMonitorJob } from "./sponsorMonitorJob";
+import { runConsolidatedNotificationJob } from "../services/consolidatedNotificationEngine";
 import { finishJobRun, startJobRun } from "./jobTelemetry";
 import { logger } from "./logger";
 
@@ -147,10 +148,9 @@ export function startCentralScheduler(): void {
   if (isCutover("CONSOLIDATED_NOTIFICATIONS")) {
     cron.schedule(JOB_SCHEDULES.CONSOLIDATED_NOTIFICATIONS, () => {
       log.info("Central scheduler: CONSOLIDATED_NOTIFICATIONS firing.");
-      runWithTelemetry("consolidatedNotifications", "Consolidated notifications digest", () => {
-        const { runConsolidatedNotificationJob } = require("../services/consolidatedNotificationEngine");
-        return runConsolidatedNotificationJob();
-      });
+      runWithTelemetry("consolidatedNotifications", "Consolidated notifications digest", () =>
+        runConsolidatedNotificationJob(),
+      ).catch((err) => log.error({ err }, "consolidatedNotifications outer error."));
     }, opts);
     log.info("Central scheduler: CONSOLIDATED_NOTIFICATIONS registered (0 7,19 * * * UTC).");
   }
diff --git a/server/utils/sponsorMonitorJob.ts b/server/utils/sponsorMonitorJob.ts
index 047f901..30d329b 100644
--- a/server/utils/sponsorMonitorJob.ts
+++ b/server/utils/sponsorMonitorJob.ts
@@ -9,8 +9,7 @@ import { applyStateMachine } from "./sponsorStateMachine";
 import { rebuildSponsorIndex } from "./sponsorSearch";
 import { cacheFlushPattern } from "./redisClient";
 import { isExpectedPublishDay } from "./ukBankHolidays";
-import { notifyUsersOfEvent, processQueuedEngineEvents } from "../services/notificationEngine";
-import { getNotificationQueue, NOTIFICATION_JOB } from "../services/jobQueue";
+import { processQueuedEngineEvents } from "../services/notificationEngine";
 import { generateHeadline, type RawDigestData } from "../services/aiDigest";
 import { withRetry } from "./dbRetry";
 import { sendAdminAlert } from "./adminAlert";