trending/ax
1
0
Fork 0
mirror of https://github.com/google/ax.git synced 2026-10-02 03:14:37 +08:00
Code Issues Packages Projects Releases Wiki Activity

Always return State_STATE_FAILED when there is an error

Browse Source
This commit is contained in:
JBD
2026-01-21 16:09:29 -08:00
parent 44024b2730
commit d8f08aacae
1 changed files with 4 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
internal/server/server.go
+4 -1
View File
@@ -50,7 +50,6 @@ func (s *Server) TriggerSession(req *proto.TriggerSessionRequest, stream grpc.Se
// Trigger the session
if err := s.controller.TriggerSession(stream.Context(), sessionID, inputs, checkpointID); err != nil {
// Send failure response
stream.Send(&proto.TriggerSessionResponse{
SessionId: sessionID,
State: proto.State_STATE_FAILED,
@@ -61,6 +60,10 @@ func (s *Server) TriggerSession(req *proto.TriggerSessionRequest, stream grpc.Se
// Get session state
session, err := s.controller.GetSession(sessionID)
if err != nil {
stream.Send(&proto.TriggerSessionResponse{
SessionId: sessionID,
State: proto.State_STATE_FAILED,
})
return err
}