Merge pull request #412 from badaitech:fix/flows-cache

fix: ensure flow clone is awaited to prevent potential race conditions

Author: yakud

.vscode/settings.json

@@ -6,16 +6,56 @@
     "source.organizeImports": "never"
   },
   "eslint.rules.customizations": [
-    { "rule": "style/*", "severity": "off", "fixable": true },
-    { "rule": "format/*", "severity": "off", "fixable": true },
-    { "rule": "*-indent", "severity": "off", "fixable": true },
-    { "rule": "*-spacing", "severity": "off", "fixable": true },
-    { "rule": "*-spaces", "severity": "off", "fixable": true },
-    { "rule": "*-order", "severity": "off", "fixable": true },
-    { "rule": "*-dangle", "severity": "off", "fixable": true },
-    { "rule": "*-newline", "severity": "off", "fixable": true },
-    { "rule": "*quotes", "severity": "off", "fixable": true },
-    { "rule": "*semi", "severity": "off", "fixable": true }
+    {
+      "rule": "style/*",
+      "severity": "off",
+      "fixable": true
+    },
+    {
+      "rule": "format/*",
+      "severity": "off",
+      "fixable": true
+    },
+    {
+      "rule": "*-indent",
+      "severity": "off",
+      "fixable": true
+    },
+    {
+      "rule": "*-spacing",
+      "severity": "off",
+      "fixable": true
+    },
+    {
+      "rule": "*-spaces",
+      "severity": "off",
+      "fixable": true
+    },
+    {
+      "rule": "*-order",
+      "severity": "off",
+      "fixable": true
+    },
+    {
+      "rule": "*-dangle",
+      "severity": "off",
+      "fixable": true
+    },
+    {
+      "rule": "*-newline",
+      "severity": "off",
+      "fixable": true
+    },
+    {
+      "rule": "*quotes",
+      "severity": "off",
+      "fixable": true
+    },
+    {
+      "rule": "*semi",
+      "severity": "off",
+      "fixable": true
+    }
   ],
   "eslint.validate": [
     "javascript",
@@ -38,5 +78,8 @@
     "scss",
     "pcss",
     "postcss"
+  ],
+  "github-actions.workflows.pinned.workflows": [
+    ".github/workflows/release.yml"
   ]
-}
+}

packages/chaingraph-executor/server/dbos/steps/ExecuteFlowAtomicStep.ts

@@ -212,7 +212,7 @@ class FlowCachedLoader {
         // Check if version matches
         if (cached.flowVersion === flowVersion) {
           DBOS.logger.debug(`Flow cache hit: ${flowId} (version: ${cached.flowVersion})`)
-          return cached.flow.clone()
+          return await cached.flow.clone() as Flow
         }
       } else {
         // Cache expired