Better handle errors on individual objects in lifecycle v2

And let `_compareRulesToList()` retry just a little bit, to limit impact/delay while ensuring message gets processed timely. Issue: BB-437
scality · Oct 13, 2023 · da37533 · da37533
1 parent b1688b6
commit da37533
Showing 1 changed file with 9 additions and 2 deletions.
diff --git a/extensions/lifecycle/tasks/LifecycleTaskV2.js b/extensions/lifecycle/tasks/LifecycleTaskV2.js
@@ -260,8 +260,15 @@ class LifecycleTaskV2 extends LifecycleTask {
         }
         return async.eachLimit(contents, CONCURRENCY_DEFAULT, (obj, cb) => {
             const applicableRules = this._getRules(bucketData, lcRules, obj);
-            return this._compare(bucketData, obj,
-                    applicableRules, log, cb);
+            return this._retryEntry({
+                logFields: {
+                    key: obj.Key,
+                    versionId: obj.VersionId,
+                    staleDate: obj.staleDate,
+                },
+                log,
+                actionFunc: done => this._compare(bucketData, obj, applicableRules, log, done),
+            }, cb);
         }, done);
     }