Merge pull request #6816 from nocodb/nc-fix/job-src

fix: jobs service
1 year ago · 804edeeacf
2 changed files with 2 additions and 1 deletions
--- 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 {
--- 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() {