Fixed some failover issues with auth/exec id for subflows

Shuffle · Sep 25, 2023 · 06d68ee · 06d68ee
1 parent 0617a78
commit 06d68ee
Show file tree

Hide file tree

Showing 2 changed files with 12 additions and 0 deletions.
diff --git a/shuffle-subflow/1.0.0/src/app.py b/shuffle-subflow/1.0.0/src/app.py
@@ -172,6 +172,12 @@ def run_subflow(self, user_apikey, workflow, argument, source_workflow="", sourc
         else:
             print("No startnode")
 
+        if len(self.full_execution["execution_id"]) > 0 and self.full_execution["execution_id"] != source_execution:
+            params["source_execution"] = self.full_execution["execution_id"]
+
+        if len(self.full_execution["authorization"]) > 0 and self.full_execution["authorization"] != source_auth:
+            params["source_auth"] = self.full_execution["authorization"]
+
         if len(str(backend_url)) > 0:
             url = "%s/api/v1/workflows/%s/execute" % (backend_url, workflow)
             print("[INFO] Changed URL to %s for this execution" % url)

diff --git a/shuffle-subflow/1.1.0/src/app.py b/shuffle-subflow/1.1.0/src/app.py
@@ -174,6 +174,12 @@ def run_subflow(self, user_apikey, workflow, argument, source_workflow="", sourc
         else:
             print("No startnode")
 
+        if len(self.full_execution["execution_id"]) > 0 and self.full_execution["execution_id"] != source_execution:
+            params["source_execution"] = self.full_execution["execution_id"]
+
+        if len(self.full_execution["authorization"]) > 0 and self.full_execution["authorization"] != source_auth:
+            params["source_auth"] = self.full_execution["authorization"]
+
         if len(str(backend_url)) > 0:
             url = "%s/api/v1/workflows/%s/execute" % (backend_url, workflow)
             print("[INFO] Changed URL to %s for this execution" % url)