From 68a643bb3aafc6bb8f7d15ebc49870dd7f53976e Mon Sep 17 00:00:00 2001
From: "Carlos R. L. Rodrigues"
 <37986729+carlos-r-l-rodrigues@users.noreply.github.com>
Date: Mon, 22 Sep 2025 01:59:59 -0300
Subject: [PATCH] fix(workflow-engine-redis): use worker connection (#13561)

What:
 * Regular redis connection does not have `maxRetriesPerRequest: null`, and the worker connection hangs.
---
 .changeset/thirty-squids-swim.md                             | 5 +++++
 .../src/utils/workflow-orchestrator-storage.ts               | 2 +-
 2 files changed, 6 insertions(+), 1 deletion(-)
 create mode 100644 .changeset/thirty-squids-swim.md

diff --git a/.changeset/thirty-squids-swim.md b/.changeset/thirty-squids-swim.md
new file mode 100644
index 0000000000..d071f8d640
--- /dev/null
+++ b/.changeset/thirty-squids-swim.md
@@ -0,0 +1,5 @@
+---
+"@medusajs/workflow-engine-redis": patch
+---
+
+fix(workflow-engine-redis): cleaner using worker connection
diff --git a/packages/modules/workflow-engine-redis/src/utils/workflow-orchestrator-storage.ts b/packages/modules/workflow-engine-redis/src/utils/workflow-orchestrator-storage.ts
index 87191f53f7..27a1d541f7 100644
--- 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(