diff --git a/extensions/lifecycle/bucketProcessor/LifecycleBucketProcessor.js b/extensions/lifecycle/bucketProcessor/LifecycleBucketProcessor.js index f7b92ace7..f2024611c 100644 --- a/extensions/lifecycle/bucketProcessor/LifecycleBucketProcessor.js +++ b/extensions/lifecycle/bucketProcessor/LifecycleBucketProcessor.js @@ -156,6 +156,14 @@ class LifecycleBucketProcessor { } }); + setInterval(() => { + const tasks = this._internalTaskScheduler.workersList().map(task => JSON.stringify(task.data.value)); + this._log.debug('current tasks in queue', { + method: 'LifecycleBucketProcessor', + tasks, + }); + }, (process.env.WORKERS_LOG_DELAY || 20000)); + this._circuitBreakerConfig = updateCircuitBreakerConfigForImplicitOutputQueue( this._lcConfig.bucketProcessor.circuitBreaker, this._lcConfig.objectProcessor.groupId,