From 80460fbe093d0d9c719f978d3783638413af1987 Mon Sep 17 00:00:00 2001 From: Eugene Nitsenko Date: Mon, 8 Apr 2024 12:11:53 +0200 Subject: [PATCH 1/2] fix(core): Add missing jobOptions to a strategy `jobQueueStrategy.add` function --- packages/core/src/job-queue/job-queue.ts | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/packages/core/src/job-queue/job-queue.ts b/packages/core/src/job-queue/job-queue.ts index 44fefaf548..0683985eef 100644 --- a/packages/core/src/job-queue/job-queue.ts +++ b/packages/core/src/job-queue/job-queue.ts @@ -99,7 +99,7 @@ export class JobQueue = object> { const isBuffered = await this.jobBufferService.add(job); if (!isBuffered) { - const addedJob = await this.jobQueueStrategy.add(job); + const addedJob = await this.jobQueueStrategy.add(job, options); return new SubscribableJob(addedJob, this.jobQueueStrategy); } else { const bufferedJob = new Job({ From 6234b87df5396e30cb29daf09cfd0aa8cc2d2226 Mon Sep 17 00:00:00 2001 From: Eugene Nitsenko Date: Wed, 17 Apr 2024 14:58:45 +0200 Subject: [PATCH 2/2] fix(core): Remove original entityTable from channels sql request --- packages/core/src/service/services/channel.service.ts | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/packages/core/src/service/services/channel.service.ts b/packages/core/src/service/services/channel.service.ts index 0f76d69c3d..57e49e7ee8 100644 --- a/packages/core/src/service/services/channel.service.ts +++ b/packages/core/src/service/services/channel.service.ts @@ -162,7 +162,7 @@ export class ChannelService { return await this.connection .getRepository(ctx, entityType) - .createQueryBuilder() + .manager.createQueryBuilder() .select(`channel.${inverseJunctionColumnName}`, 'channelId') .from(junctionTableName, 'channel') .where(`channel.${junctionColumnName} = :entityId`, { entityId })