diff --git a/apps/scheduler/job-queue.ts b/apps/scheduler/job-queue.ts index 62305ae8..3792e47e 100644 --- a/apps/scheduler/job-queue.ts +++ b/apps/scheduler/job-queue.ts @@ -55,7 +55,9 @@ const workerQueue = new WokerQueue(new SQSClient({}), env.WORKER_QUEUE_URL); export async function scheduleJobs(chainId: string): Promise { for (const job of AllNetworkConfigs[chainId].workerJobs) { - console.log(`Initializing job ${job.name}-${chainId}-init`); - await workerQueue.sendWithInterval(JSON.stringify({ name: job.name, chain: chainId }), job.interval); + if (job.name === 'sync-changed-pools') { + console.log(`Initializing job ${job.name}-${chainId}-init`); + await workerQueue.sendWithInterval(JSON.stringify({ name: job.name, chain: chainId }), job.interval); + } } }