wip: Add logging

n8n-io · Dec 27, 2024 · 7a50d15 · 7a50d15
1 parent 5a541c2
commit 7a50d15
Showing 1 changed file with 9 additions and 0 deletions.
diff --git a/packages/cli/src/concurrency/concurrency-control.service.ts b/packages/cli/src/concurrency/concurrency-control.service.ts
@@ -92,6 +92,15 @@ export class ConcurrencyControlService {
 		this.productionQueue.on('execution-released', async (executionId) => {
 			this.logger.debug('Execution released', { executionId });
 		});
+
+		this.evaluationQueue.on('execution-throttled', ({ executionId }) => {
+			this.logger.debug('Evaluation execution throttled', { executionId });
+			this.eventService.emit('execution-throttled', { executionId });
+		});
+
+		this.evaluationQueue.on('execution-released', async (executionId) => {
+			this.logger.debug('Evaluation execution released', { executionId });
+		});
 	}
 
 	/**