From ebd9e93bf1cb7dc88490dad0c7e1104b148eaf50 Mon Sep 17 00:00:00 2001 From: Henit Chobisa Date: Mon, 30 Dec 2024 16:28:00 +0530 Subject: [PATCH] fix: remove celery url and default to amqp url (#2051) --- silo/src/apps/engine/worker/celery.ts | 2 +- silo/src/env.ts | 1 - 2 files changed, 1 insertion(+), 2 deletions(-) diff --git a/silo/src/apps/engine/worker/celery.ts b/silo/src/apps/engine/worker/celery.ts index 440340e9e2..7f80380143 100644 --- a/silo/src/apps/engine/worker/celery.ts +++ b/silo/src/apps/engine/worker/celery.ts @@ -7,7 +7,7 @@ export class CeleryProducer { private mq: MQ | undefined; private initQueue = async (options: TMQEntityOptions) => { - this.mq = new MQ(options, env.CELERY_AMQP_URL); + this.mq = new MQ(options, env.AMQP_URL); await this.mq.connect(); logger.info(`Message Queue ${options.queueName} connected successfully 🐇🐇🐰`); }; diff --git a/silo/src/env.ts b/silo/src/env.ts index ee162f63a1..31991c7d90 100644 --- a/silo/src/env.ts +++ b/silo/src/env.ts @@ -10,7 +10,6 @@ const envSchema = z.object({ DEDUP_INTERVAL: z.string().optional().default("2"), DB_URL: z.string().default("postgres://postgres:password@localhost:5432/silo"), AMQP_URL: z.string().default("amqp://guest:guest@localhost:5672"), - CELERY_AMQP_URL: z.string().default("amqp://guest:guest@localhost:5672"), REDIS_URL: z.string().default("redis://localhost:6379"), SENTRY_DSN: z.string().optional(), PG_SCHEMA: z.string().optional(),