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(),