Merge pull request #1856 from yashsinghcodes/nightly

fix: subflow stream result returning 400
2025-10-29 13:00:07 +05:30
parent f50ba78a56 f027e6196c
commit dd052857e9
1 changed files with 5 additions and 0 deletions
@@ -2116,6 +2116,11 @@ func handleSubflowPoller(ctx context.Context, workflowExecution shuffle.Workflow
 		}
 	}

+	if len(data) == 0 {
+		log.Printf("[WARNING] Stream result missing execution ID and authorization; injecting them from workflow execution")
+		data = fmt.Sprintf(`{"execution_id": "%s", "authorization": "%s"}`, workflowExecution.ExecutionId, workflowExecution.Authorization)
+	}
+
 	req, err := http.NewRequest(
 		"POST",
 		streamResultUrl,