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

Remove duplicate method

Browse Source
This commit is contained in:
JBD
2026-01-24 13:26:27 -08:00
parent 470816f103
commit a1c1e5f52f
2 changed files with 2 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files
internal/controller/controller.go
-5
View File
@@ -114,11 +114,6 @@ func (d *Controller) TriggerSession(ctx context.Context, sessionID string, input
return nil
}
// GetSession retrieves a session by ID.
func (d *Controller) GetSession(ctx context.Context, sessionID string) (*Session, error) {
return d.sessionManager.GetSession(sessionID)
}
// LoadSession loads a session from event log.
func (d *Controller) LoadSession(ctx context.Context, sessionID string) (*Session, error) {
return d.sessionManager.LoadSession(sessionID)
internal/server/server.go
+2 -2
View File
@@ -57,7 +57,7 @@ func (s *Server) TriggerSession(req *proto.TriggerSessionRequest, stream grpc.Se
}
// Get session state
session, err := s.controller.GetSession(stream.Context(), sessionID)
session, err := s.controller.LoadSession(stream.Context(), sessionID)
if err != nil {
stream.Send(&proto.TriggerSessionResponse{
State: proto.State_STATE_FAILED,
@@ -81,7 +81,7 @@ func (s *Server) GetSession(ctx context.Context, req *proto.GetSessionRequest) (
}
// Load session if not already loaded
session, err := s.controller.GetSession(ctx, req.SessionId)
session, err := s.controller.LoadSession(ctx, req.SessionId)
if err != nil {
// Try loading from event log
session, err = s.controller.LoadSession(ctx, req.SessionId)