Browse Source

feat: worker reset

pull/6899/head
mertmit 1 year ago
parent
commit
3601c5fb09
  1. 1
      packages/nocodb/src/interface/Jobs.ts
  2. 2
      packages/nocodb/src/modules/jobs/redis/jobs.service.ts

1
packages/nocodb/src/interface/Jobs.ts

@ -35,4 +35,5 @@ export enum InstanceTypes {
export enum WorkerCommands { export enum WorkerCommands {
RESUME_LOCAL = 'resumeLocal', RESUME_LOCAL = 'resumeLocal',
PAUSE_LOCAL = 'pauseLocal', PAUSE_LOCAL = 'pauseLocal',
RESET = 'reset',
} }

2
packages/nocodb/src/modules/jobs/redis/jobs.service.ts

@ -7,7 +7,7 @@ import { JobsRedisService } from '~/modules/jobs/redis/jobs-redis.service';
@Injectable() @Injectable()
export class JobsService implements OnModuleInit { export class JobsService implements OnModuleInit {
private logger = new Logger(JobsService.name); protected logger = new Logger(JobsService.name);
constructor( constructor(
@InjectQueue(JOBS_QUEUE) public readonly jobsQueue: Queue, @InjectQueue(JOBS_QUEUE) public readonly jobsQueue: Queue,

Loading…
Cancel
Save