From 7bc7bce2d68f6c718680f067e2a0a9d5746dd855 Mon Sep 17 00:00:00 2001 From: mertmit Date: Fri, 27 Oct 2023 16:31:24 +0000 Subject: [PATCH] fix: jobs service --- packages/nocodb/src/interface/Jobs.ts | 1 + packages/nocodb/src/modules/jobs/redis/jobs.service.ts | 2 +- 2 files changed, 2 insertions(+), 1 deletion(-) diff --git a/packages/nocodb/src/interface/Jobs.ts b/packages/nocodb/src/interface/Jobs.ts index ef79ac4a72..93a1127af0 100644 --- a/packages/nocodb/src/interface/Jobs.ts +++ b/packages/nocodb/src/interface/Jobs.ts @@ -9,6 +9,7 @@ export enum JobTypes { BaseDelete = 'base-delete', UpdateModelStat = 'update-model-stat', UpdateWsStat = 'update-ws-stats', + UpdateSrcStat = 'update-source-stat', } export enum JobStatus { diff --git a/packages/nocodb/src/modules/jobs/redis/jobs.service.ts b/packages/nocodb/src/modules/jobs/redis/jobs.service.ts index 9a18801e8b..5e3dcb14a2 100644 --- a/packages/nocodb/src/modules/jobs/redis/jobs.service.ts +++ b/packages/nocodb/src/modules/jobs/redis/jobs.service.ts @@ -6,7 +6,7 @@ import { JOBS_QUEUE, JobStatus } from '~/interface/Jobs'; @Injectable() export class JobsService implements OnModuleInit { - constructor(@InjectQueue(JOBS_QUEUE) private readonly jobsQueue: Queue) {} + constructor(@InjectQueue(JOBS_QUEUE) protected readonly jobsQueue: Queue) {} // pause primary instance queue async onModuleInit() {