log current queue tasks

scality · Oct 6, 2023 · ecc6c67 · ecc6c67
1 parent f0a661e
commit ecc6c67
Showing 1 changed file with 8 additions and 0 deletions.
diff --git 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,