diff --git a/.changeset/early-rice-marry.md b/.changeset/early-rice-marry.md
new file mode 100644
index 0000000000..b51f3b49d0
--- /dev/null
+++ b/.changeset/early-rice-marry.md
@@ -0,0 +1,6 @@
+---
+"@medusajs/event-bus-redis": patch
+"@medusajs/workflow-engine-redis": patch
+---
+
+Chore/workflow engine loader redis
diff --git a/packages/event-bus-redis/src/loaders/index.ts b/packages/event-bus-redis/src/loaders/index.ts
index a405013078..40028b57e1 100644
--- a/packages/event-bus-redis/src/loaders/index.ts
+++ b/packages/event-bus-redis/src/loaders/index.ts
@@ -27,7 +27,9 @@ export default async ({
   })
 
   try {
-    await connection.connect()
+    await new Promise(async resolve => {
+      await connection.connect(resolve)
+    })
     logger?.info(`Connection to Redis in module 'event-bus-redis' established`)
   } catch (err) {
     logger?.error(
diff --git a/packages/workflow-engine-redis/src/loaders/redis.ts b/packages/workflow-engine-redis/src/loaders/redis.ts
index dd8a974c0f..df82f0f4b8 100644
--- a/packages/workflow-engine-redis/src/loaders/redis.ts
+++ b/packages/workflow-engine-redis/src/loaders/redis.ts
@@ -7,7 +7,7 @@ export default async ({
   container,
   logger,
   options,
-                        dataLoaderOnly
+  dataLoaderOnly,
 }: LoaderOptions): Promise<void> => {
   const {
     url,
@@ -80,7 +80,9 @@ async function getConnection(url, redisOptions) {
     ...(redisOptions ?? {}),
   })
 
-  await connection.connect()
+  await new Promise(async (resolve) => {
+    await connection.connect(resolve)
+  })
 
   return connection
 }