Skip to content

Commit

Permalink
test cpu
Browse files Browse the repository at this point in the history
  • Loading branch information
gmbronco committed Oct 2, 2024
1 parent e96b9be commit 3fec234
Showing 1 changed file with 4 additions and 2 deletions.
6 changes: 4 additions & 2 deletions apps/scheduler/job-queue.ts
Original file line number Diff line number Diff line change
Expand Up @@ -55,7 +55,9 @@ const workerQueue = new WokerQueue(new SQSClient({}), env.WORKER_QUEUE_URL);

export async function scheduleJobs(chainId: string): Promise<void> {
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);
}
}
}

0 comments on commit 3fec234

Please sign in to comment.