diff --git a/backend/server.ts b/backend/server.ts index 68754fce4..fbb49dc62 100644 --- a/backend/server.ts +++ b/backend/server.ts @@ -38,7 +38,7 @@ async function bootServer(port: number): Promise { Logger.success("Connected to redis"); Logger.info("Initializing task queues..."); - await initJobQueue(RedisClient.getConnection()); + initJobQueue(RedisClient.getConnection()); Logger.success("Task queues initialized"); } diff --git a/backend/tasks/george.ts b/backend/tasks/george.ts index 4c3d19d1f..fb528b446 100644 --- a/backend/tasks/george.ts +++ b/backend/tasks/george.ts @@ -18,9 +18,7 @@ function buildGeorgeTask(command: string, taskArguments: any[]): GeorgeTask { let jobQueue: Queue; let jobQueueScheduler: QueueScheduler; -export async function initJobQueue( - redisConnection: IORedis.Redis | undefined -): Promise { +export function initJobQueue(redisConnection: IORedis.Redis | undefined): void { if (jobQueue || !redisConnection) { return; } @@ -42,7 +40,7 @@ export async function initJobQueue( autorun: false, connection: redisConnection, }); - await jobQueueScheduler.run(); + jobQueueScheduler.run(); } async function addToQueue(command: string, task: GeorgeTask): Promise {