|
|
@ -11,9 +11,11 @@ export class JobsService { |
|
|
|
@InjectQueue(JOBS_QUEUE) private readonly jobsQueue: Queue, |
|
|
|
@InjectQueue(JOBS_QUEUE) private readonly jobsQueue: Queue, |
|
|
|
private readonly fallbackQueueService: QueueService, |
|
|
|
private readonly fallbackQueueService: QueueService, |
|
|
|
) { |
|
|
|
) { |
|
|
|
this.activeQueue = process.env.NC_REDIS_URL |
|
|
|
this.activeQueue = this.fallbackQueueService; |
|
|
|
? this.jobsQueue |
|
|
|
/* process.env.NC_REDIS_URL |
|
|
|
: this.fallbackQueueService; |
|
|
|
? this.jobsQueue |
|
|
|
|
|
|
|
: this.fallbackQueueService; |
|
|
|
|
|
|
|
*/ |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
async jobStatus(jobId: string) { |
|
|
|
async jobStatus(jobId: string) { |
|
|
|