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