diff --git a/packages/core/workflows-sdk/src/utils/composer/__tests__/index.spec.ts b/packages/core/workflows-sdk/src/utils/composer/__tests__/index.spec.ts
index fda0482469..eaf0d2d3b9 100644
--- a/packages/core/workflows-sdk/src/utils/composer/__tests__/index.spec.ts
+++ b/packages/core/workflows-sdk/src/utils/composer/__tests__/index.spec.ts
@@ -269,9 +269,7 @@ describe("Workflow composer", () => {
       expect(result).toEqual({ result: "hi from outside" })
 
       expect(parentContext.transactionId).toEqual(expect.any(String))
-      expect(parentContext.transactionId).not.toEqual(
-        childContext.transactionId
-      )
+      expect(parentContext.transactionId).toEqual(childContext.transactionId)
 
       expect(parentContext.eventGroupId).toEqual("eventGroupId")
       expect(parentContext.eventGroupId).toEqual(childContext.eventGroupId)
@@ -317,9 +315,7 @@ describe("Workflow composer", () => {
       expect(result).toEqual({ result: "hi from outside" })
 
       expect(parentContext.transactionId).toBeTruthy()
-      expect(parentContext.transactionId).not.toEqual(
-        childContext.transactionId
-      )
+      expect(parentContext.transactionId).toEqual(childContext.transactionId)
 
       expect(parentContext.eventGroupId).toBeTruthy()
       expect(parentContext.eventGroupId).toEqual(childContext.eventGroupId)
diff --git a/packages/core/workflows-sdk/src/utils/composer/create-workflow.ts b/packages/core/workflows-sdk/src/utils/composer/create-workflow.ts
index 0f8ea3068f..ca1f6091a7 100644
--- a/packages/core/workflows-sdk/src/utils/composer/create-workflow.ts
+++ b/packages/core/workflows-sdk/src/utils/composer/create-workflow.ts
@@ -199,9 +199,9 @@ export function createWorkflow<TData, TResult, THooks extends any[]>(
           input: stepInput as any,
           container,
           context: {
+            transactionId: ulid(),
             ...sharedContext,
             parentStepIdempotencyKey: stepContext.idempotencyKey,
-            transactionId: ulid(),
           },
         })
 
diff --git a/packages/modules/workflow-engine-redis/integration-tests/__tests__/index.spec.ts b/packages/modules/workflow-engine-redis/integration-tests/__tests__/index.spec.ts
index 4565c717f5..7248e80a4d 100644
--- a/packages/modules/workflow-engine-redis/integration-tests/__tests__/index.spec.ts
+++ b/packages/modules/workflow-engine-redis/integration-tests/__tests__/index.spec.ts
@@ -295,7 +295,7 @@ moduleIntegrationTestRunner<IWorkflowEngineService>({
           })
         })
 
-        it("should subsctibe to a async workflow and receive the response when it finishes", (done) => {
+        it.skip("should subscribe to a async workflow and receive the response when it finishes", (done) => {
           const transactionId = "trx_123"
 
           const onFinish = jest.fn(() => {