|
|
@@ -99,13 +99,8 @@ export class JobQueue<Data extends JobData<Data> = object> {
|
|
|
|
|
|
const isBuffered = await this.jobBufferService.add(job);
|
|
|
if (!isBuffered) {
|
|
|
- try {
|
|
|
const addedJob = await this.jobQueueStrategy.add(job);
|
|
|
return new SubscribableJob(addedJob, this.jobQueueStrategy);
|
|
|
- } catch (err: any) {
|
|
|
- Logger.error(`Could not add Job to "${this.name}" queue`, undefined, err.stack);
|
|
|
- return new SubscribableJob(job, this.jobQueueStrategy);
|
|
|
- }
|
|
|
} else {
|
|
|
const bufferedJob = new Job({
|
|
|
...job,
|