fix: resume queue in content-publishing when Capacity is available (#393)

JoeCap08055 · web-flow · commit 83bd6236fbec · 2024-08-16T15:41:13.000Z
# Description Resume queue when Capacity is available (was logging event, but not resuming queue) # Acceptance Criteria - [x] Publishing queue is resumed when Capacity becomes available Closes #392
diff --git a/services/content-publishing/apps/worker/src/publisher/publishing.service.ts b/services/content-publishing/apps/worker/src/publisher/publishing.service.ts
@@ -112,6 +112,7 @@ export class PublishingService extends BaseConsumer implements OnApplicationBoot
     if (await this.publishQueue.isPaused()) {
       this.logger.debug('Received capacity.available event');
     }
+    await this.publishQueue.resume();
     try {
       this.schedulerRegistry.deleteTimeout(CAPACITY_EPOCH_TIMEOUT_NAME);
     } catch (err) {

Original file line number	Diff line number	Diff line change
`@@ -112,6 +112,7 @@ export class PublishingService extends BaseConsumer implements OnApplicationBoot`
`112`	`112`	`if (await this.publishQueue.isPaused()) {`
`113`	`113`	`this.logger.debug('Received capacity.available event');`
`114`	`114`	`}`
	`115`	`+ await this.publishQueue.resume();`
`115`	`116`	`try {`
`116`	`117`	`this.schedulerRegistry.deleteTimeout(CAPACITY_EPOCH_TIMEOUT_NAME);`
`117`	`118`	`} catch (err) {`