fix: Allow removing maxRetryDelay from queue

timgit · Dec 12, 2024 · 4fc34a0 · 4fc34a0
1 parent 9904d7c
commit 4fc34a0
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 5 deletions.
diff --git a/src/plans.js b/src/plans.js
@@ -395,7 +395,7 @@ function updateQueue (schema) {
       retry_limit = COALESCE($3, retry_limit),
       retry_delay = COALESCE($4, retry_delay),
       retry_backoff = COALESCE($5, retry_backoff),
-      max_retry_delay = COALESCE($6, max_retry_delay),
+      max_retry_delay = $6,
       expire_seconds = COALESCE($7, expire_seconds),
       retention_minutes = COALESCE($8, retention_minutes),
       dead_letter = COALESCE($9, dead_letter),

diff --git a/test/queueTest.js b/test/queueTest.js
@@ -131,7 +131,7 @@ describe('queues', function () {
     const createProps = {
       policy: 'standard',
       retryLimit: 1,
-      retryBackoff: false,
+      retryBackoff: true,
       retryDelay: 2,
       maxRetryDelay: 3,
       expireInSeconds: 4,
@@ -161,9 +161,9 @@ describe('queues', function () {
     const updateProps = {
       policy: 'short',
       retryLimit: 1,
-      retryBackoff: true,
+      retryBackoff: false,
       retryDelay: 2,
-      maxRetryDelay: 3,
+      maxRetryDelay: undefined,
       expireInSeconds: 4,
       retentionMinutes: 5,
       deadLetter
@@ -177,7 +177,7 @@ describe('queues', function () {
     assert.strictEqual(updateProps.retryLimit, queueObj.retryLimit)
     assert.strictEqual(updateProps.retryBackoff, queueObj.retryBackoff)
     assert.strictEqual(updateProps.retryDelay, queueObj.retryDelay)
-    assert.strictEqual(updateProps.maxRetryDelay, queueObj.maxRetryDelay)
+    assert.strictEqual(null, queueObj.maxRetryDelay)
     assert.strictEqual(updateProps.expireInSeconds, queueObj.expireInSeconds)
     assert.strictEqual(updateProps.retentionMinutes, queueObj.retentionMinutes)
     assert.strictEqual(updateProps.deadLetter, queueObj.deadLetter)