Skip to content

Commit

Permalink
Disable process-old-results job on data-sink-worker (#2339)
Browse files Browse the repository at this point in the history
  • Loading branch information
sausage-todd authored Apr 5, 2024
1 parent ece59cf commit a7f1eb0
Showing 1 changed file with 1 addition and 14 deletions.
15 changes: 1 addition & 14 deletions services/apps/data_sink_worker/src/main.ts
Original file line number Diff line number Diff line change
Expand Up @@ -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'

Expand Down Expand Up @@ -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)
Expand Down

0 comments on commit a7f1eb0

Please sign in to comment.