From 6a280b29294b4864afa2591f45ddde1c630e7aae Mon Sep 17 00:00:00 2001
From: Bolek Kulbabinski <1416262+bolekk@users.noreply.github.com>
Date: Fri, 4 Sep 2026 09:46:18 -0700
Subject: [PATCH] [HTTP Trigger] Respond to Gateway before emitting an event

---
 http_trigger/trigger/connector_handler.go | 13 ++++++-------
 1 file changed, 6 insertions(+), 7 deletions(-)

diff --git a/http_trigger/trigger/connector_handler.go b/http_trigger/trigger/connector_handler.go
index 67b57158a..d4c52943b 100644
--- a/http_trigger/trigger/connector_handler.go
+++ b/http_trigger/trigger/connector_handler.go
@@ -359,18 +359,17 @@ func (h *connectorHandler) processTrigger(ctx context.Context, gatewayID string,
 	}
 	l.Debug("Workflow triggered successfully")
 
-	// Emit TriggerExecutionStarted event
-	if emitErr := events.EmitTriggerExecutionStarted(ctx, labeler); emitErr != nil {
-		l.Errorw("failed to emit trigger execution started event", "error", emitErr)
-	}
-
-	l.Debug("Sending response to gateway")
 	h.sendResponse(ctx, gatewayID, resp)
-
 	err = h.cacheRequestResponse(ctx, req, workflowMetadata.WorkflowID, workflowExecutionID, resp, l)
 	if err != nil {
 		l.Errorw("Failed to cache request response", "error", err)
 	}
+	l.Debug("Sent response to gateway")
+
+	if emitErr := events.EmitTriggerExecutionStarted(ctx, labeler); emitErr != nil {
+		l.Errorw("failed to emit trigger execution started event", "error", emitErr)
+	}
+	l.Debug("Trigger event processed")
 }
 
 type WorkflowMetadata struct {