diff --git a/services/apps/data_sink_worker/src/main.ts b/services/apps/data_sink_worker/src/main.ts
index 36e67d58e3..37cf65ae18 100644
--- a/services/apps/data_sink_worker/src/main.ts
+++ b/services/apps/data_sink_worker/src/main.ts
@@ -19,7 +19,6 @@ import {
 } from './conf'
 import { WorkerQueueReceiver } from './queue'
 import { getRedisClient } from '@crowd/redis'
-import { processOldResultsJob } from './jobs/processOldResults'
 import { getUnleashClient } from '@crowd/feature-flags'
 import { Client as TemporalClient, getTemporalClient } from '@crowd/temporal'
 
@@ -95,19 +94,7 @@ setImmediate(async () => {
     await searchSyncWorkerEmitter.init()
     await dataWorkerEmitter.init()
 
-    await Promise.all([
-      processOldResultsJob(
-        dbConnection,
-        redisClient,
-        nodejsWorkerEmitter,
-        searchSyncWorkerEmitter,
-        dataWorkerEmitter,
-        unleash,
-        temporal,
-        log,
-      ),
-      queue.start(),
-    ])
+    await queue.start()
   } catch (err) {
     log.error({ err }, 'Failed to start queues!')
     process.exit(1)