fix(workflow-engine-redis): use worker connection (#13561)

What: * Regular redis connection does not have `maxRetriesPerRequest: null`, and the worker connection hangs.
2025-09-22 01:59:59 -03:00
parent 8a4c10d7f8
commit 68a643bb3a
2 changed files with 6 additions and 1 deletions
--- a/.changeset/thirty-squids-swim.md
+++ b/.changeset/thirty-squids-swim.md
@@ -0,0 +1,5 @@
+---
+"@medusajs/workflow-engine-redis": patch
+---
+
+fix(workflow-engine-redis): cleaner using worker connection
--- a/packages/modules/workflow-engine-redis/src/utils/workflow-orchestrator-storage.ts
+++ b/packages/modules/workflow-engine-redis/src/utils/workflow-orchestrator-storage.ts
@@ -190,7 +190,7 @@ export class RedisDistributedTransactionStorage
        async () => {
          await this.clearExpiredExecutions()
        },
-        { connection: this.redisClient }
+        workerOptions
      )

      await this.cleanerQueue_?.add(