fix: event must be capitalized when streaming (#2030)

1 month ago · 1f9e1cb1c7
parent 6d8cde9665
commit 1f9e1cb1c7
1 changed files with 4 additions and 4 deletions
--- a/backend/application/workflow/workflow.go
+++ b/backend/application/workflow/workflow.go
@ -1322,10 +1322,10 @@ func mergeBatchModeNodes(parent, inner *workflow.NodeResult) *workflow.NodeResul
 type StreamRunEventType string

 const (
-	DoneEvent      StreamRunEventType = "done"
-	MessageEvent   StreamRunEventType = "message"
-	ErrEvent       StreamRunEventType = "error"
-	InterruptEvent StreamRunEventType = "interrupt"
+	DoneEvent      StreamRunEventType = "Done"
+	MessageEvent   StreamRunEventType = "Message"
+	ErrEvent       StreamRunEventType = "Error"
+	InterruptEvent StreamRunEventType = "Interrupt"
 )

 func convertStreamRunEvent(workflowID int64) func(msg *entity.Message) (res *workflow.OpenAPIStreamRunFlowResponse, err error) {