From f027e6196c97ce90460e16ae9e17b09ee1b5bd62 Mon Sep 17 00:00:00 2001 From: yashsinghcodes Date: Tue, 28 Oct 2025 15:50:49 +0530 Subject: [PATCH] fix: subflow stream result returning 400 --- functions/onprem/worker/worker.go | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/functions/onprem/worker/worker.go b/functions/onprem/worker/worker.go index 13c507d3..5a858888 100644 --- a/functions/onprem/worker/worker.go +++ b/functions/onprem/worker/worker.go @@ -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,