Properly initialize retry params for lifecycle

extensions/gc/tasks/GarbageCollectorTask.js

@@ -5,6 +5,7 @@ const { ObjectMD } = require('arsenal').models;
 const { attachReqUids } = require('../../../lib/clients/utils');
 const BackbeatTask = require('../../../lib/tasks/BackbeatTask');
 const { GarbageCollectorMetrics } = require('../GarbageCollectorMetrics');
+/** @typedef { import('../GarbageCollector.js') } GarbageCollector */
 
 class GarbageCollectorTask extends BackbeatTask {
     /**
@@ -14,13 +15,9 @@ class GarbageCollectorTask extends BackbeatTask {
      * @param {GarbageCollector} gc - garbage collector instance
      */
     constructor(gc) {
-        super();
         const gcState = gc.getStateVars();
+        super(gcState.gcConfig?.consumer.retry);
         Object.assign(this, gcState);
-        const retryParams = gcState.gcConfig?.consumer.retry;
-        if (retryParams) {
-            this.retryParams = retryParams;
-        }
     }
 
     // helper method needed for replication generated entries in which the

extensions/lifecycle/bucketProcessor/LifecycleBucketProcessor.js

@@ -103,7 +103,7 @@ class LifecycleBucketProcessor {
             transport,
         }, this._log);
 
-        this.retryWrapper = new BackbeatTask();
+        this.retryWrapper = new BackbeatTask(lcConfig.bucketProcessor.retry);
 
         // helper object to facilitate the tracking of the the latest x
         // noncurrent versions of an object when the field
@@ -176,6 +176,7 @@ class LifecycleBucketProcessor {
     getStateVars() {
         return {
             producer: this._producer,
+            processConfig: this._lcConfig.bucketProcessor,
             bootstrapList: this._repConfig.destination.bootstrapList,
             bucketTasksTopic: this._lcConfig.bucketTasksTopic,
             objectTasksTopic: this._lcConfig.objectTasksTopic,

extensions/lifecycle/conductor/LifecycleConductor.js

@@ -530,7 +530,7 @@ class LifecycleConductor {
         let marker = initMarker;
         let nEnqueued = 0;
         const start = new Date();
-        const retryWrapper = new BackbeatTask();
+        const retryWrapper = new BackbeatTask(this.lcConfig.conductor.retry);
 
         this.lastSentId = null;
         this.lastSentVersion = -1;

extensions/lifecycle/objectProcessor/LifecycleObjectProcessor.js

@@ -24,7 +24,6 @@ const logIdFromType = {
  * endpoint using the S3 API.
  */
 class LifecycleObjectProcessor extends EventEmitter {
-
     /**
      * Constructor of LifecycleObjectProcessor
      *
@@ -65,7 +64,7 @@ class LifecycleObjectProcessor extends EventEmitter {
             transport,
         }, this._log);
 
-        this.retryWrapper = new BackbeatTask();
+        this.retryWrapper = new BackbeatTask(this._processConfig.retry);
     }
 
     getProcessorType() {

extensions/lifecycle/tasks/LifecycleDeleteObjectTask.js

@@ -5,6 +5,7 @@ const ObjectMD = require('arsenal').models.ObjectMD;
 const BackbeatTask = require('../../../lib/tasks/BackbeatTask');
 const { attachReqUids } = require('../../../lib/clients/utils');
 const { LifecycleMetrics } = require('../LifecycleMetrics');
+/** @typedef { import('../objectProcessor/LifecycleObjectProcessor.js') } LifecycleObjectProcessor */
 
 class ObjectLockedError extends Error {}
 class PendingReplicationError extends Error {}
@@ -18,7 +19,7 @@ class LifecycleDeleteObjectTask extends BackbeatTask {
      */
     constructor(proc) {
         const procState = proc.getStateVars();
-        super();
+        super(procState.processConfig?.retry);
         Object.assign(this, procState);
         this.objectMD = null;
     }

extensions/lifecycle/tasks/LifecycleRequeueTask.js

@@ -7,6 +7,7 @@ const ObjectMD = require('arsenal').models.ObjectMD;
 
 const BackbeatTask = require('../../../lib/tasks/BackbeatTask');
 const { LifecycleMetrics } = require('../LifecycleMetrics');
+/** @typedef { import('../objectProcessor/LifecycleObjectProcessor.js') } LifecycleObjectProcessor */
 
 class LifecycleRequeueTask extends BackbeatTask {
 
@@ -19,7 +20,7 @@ class LifecycleRequeueTask extends BackbeatTask {
      */
     constructor(proc, processName) {
         const procState = proc.getStateVars();
-        super();
+        super(procState.processConfig?.retry);
         Object.assign(this, procState);
         this.processName = processName;
     }

extensions/lifecycle/tasks/LifecycleTask.js

@@ -85,7 +85,7 @@ class LifecycleTask extends BackbeatTask {
      */
     constructor(lp) {
         const lpState = lp.getStateVars();
-        super();
+        super(lpState.processConfig?.retry);
         Object.assign(this, lpState);
 
         const { transitionOneDayEarlier, expireOneDayEarlier, timeProgressionFactor } = this.lcOptions;

extensions/lifecycle/tasks/LifecycleUpdateExpirationTask.js

@@ -6,6 +6,7 @@ const BackbeatTask = require('../../../lib/tasks/BackbeatTask');
 const ActionQueueEntry = require('../../../lib/models/ActionQueueEntry');
 const { LifecycleMetrics } = require('../LifecycleMetrics');
 const locations = require('../../../conf/locationConfig.json') || {};
+/** @typedef { import('../objectProcessor/LifecycleObjectProcessor.js') } LifecycleObjectProcessor */
 
 class LifecycleUpdateExpirationTask extends BackbeatTask {
     /**
@@ -16,7 +17,7 @@ class LifecycleUpdateExpirationTask extends BackbeatTask {
      */
     constructor(proc) {
         const procState = proc.getStateVars();
-        super();
+        super(procState.processConfig?.retry);
         Object.assign(this, procState);
     }
 

extensions/lifecycle/tasks/LifecycleUpdateTransitionTask.js

@@ -6,7 +6,7 @@ const BackbeatTask = require('../../../lib/tasks/BackbeatTask');
 const ActionQueueEntry = require('../../../lib/models/ActionQueueEntry');
 const ObjectMD = require('arsenal').models.ObjectMD;
 const { LifecycleMetrics } = require('../LifecycleMetrics');
-
+/** @typedef { import('../objectProcessor/LifecycleObjectProcessor.js') } LifecycleObjectProcessor */
 
 class LifecycleUpdateTransitionTask extends BackbeatTask {
     /**
@@ -17,7 +17,7 @@ class LifecycleUpdateTransitionTask extends BackbeatTask {
      */
     constructor(proc) {
         const procState = proc.getStateVars();
-        super();
+        super(procState.processConfig?.retry);
         Object.assign(this, procState);
     }
 

lib/tasks/BackbeatTask.js

@@ -5,8 +5,8 @@ const BackOff = require('backo');
  */
 class BackbeatTask {
 
-    constructor() {
-        this.retryParams = {
+    constructor(retryParams) {
+        this.retryParams = retryParams || {
             timeoutS: 300,
             backoff: {
                 min: 1000,

package.json

@@ -1,6 +1,6 @@
 {
   "name": "backbeat",
-  "version": "8.6.52",
+  "version": "8.6.53",
   "description": "Asynchronous queue and job manager",
   "main": "index.js",
   "scripts": {

tests/unit/lifecycle/LifecycleRetriggerRestoreTask.spec.js

@@ -11,7 +11,7 @@ const {
     ProcessorMock,
 } = require('../mocks');
 
-describe('LifecycleResetTransitionInProgressTask', () => {
+describe('LifecycleRetriggerRestoreTask', () => {
     let backbeatMetadataProxyClient;
     let objectProcessor;
     let task;