diff --git a/quickstart/eino_assistant/cmd/einoagent/agent/agent.go b/quickstart/eino_assistant/cmd/einoagent/agent/agent.go index fc4bff1..a1aed8e 100644 --- a/quickstart/eino_assistant/cmd/einoagent/agent/agent.go +++ b/quickstart/eino_assistant/cmd/einoagent/agent/agent.go @@ -25,12 +25,12 @@ import ( "os" "sync" - "github.com/cloudwego/eino-examples/quickstart/eino_assistant/eino/einoagent" - "github.com/cloudwego/eino-examples/quickstart/eino_assistant/pkg/mem" - "github.com/cloudwego/eino-ext/callbacks/langfuse" "github.com/cloudwego/eino/callbacks" "github.com/cloudwego/eino/compose" "github.com/cloudwego/eino/schema" + + "github.com/cloudwego/eino-examples/quickstart/eino_assistant/eino/einoagent" + "github.com/cloudwego/eino-examples/quickstart/eino_assistant/pkg/mem" ) var memory = mem.GetDefaultMemory() @@ -121,7 +121,7 @@ func RunAgent(ctx context.Context, id string, msg string) (*schema.StreamReader[ conversation.Append(fullMsg) }() - outter: + outer: for { select { case <-ctx.Done(): @@ -131,7 +131,7 @@ func RunAgent(ctx context.Context, id string, msg string) (*schema.StreamReader[ chunk, err := srs[1].Recv() if err != nil { if errors.Is(err, io.EOF) { - break outter + break outer } } diff --git a/quickstart/eino_assistant/cmd/einoagent/agent/server.go b/quickstart/eino_assistant/cmd/einoagent/agent/server.go index 89df473..93b4af6 100644 --- a/quickstart/eino_assistant/cmd/einoagent/agent/server.go +++ b/quickstart/eino_assistant/cmd/einoagent/agent/server.go @@ -116,7 +116,7 @@ func HandleChat(ctx context.Context, c *app.RequestContext) { log.Printf("[Chat] Finished chat with ID: %s\n", id) }() -outter: +outer: for { select { case <-ctx.Done(): @@ -126,11 +126,11 @@ outter: msg, err := sr.Recv() if errors.Is(err, io.EOF) { log.Printf("[Chat] EOF received for chat ID: %s\n", id) - break outter + break outer } if err != nil { log.Printf("[Chat] Error receiving message: %v\n", err) - break outter + break outer } err = s.Publish(&sse.Event{ @@ -138,7 +138,7 @@ outter: }) if err != nil { log.Printf("[Chat] Error publishing message: %v\n", err) - break outter + break outer } } } diff --git a/quickstart/eino_assistant/cmd/einoagentcli/main.go b/quickstart/eino_assistant/cmd/einoagentcli/main.go index 50fe13b..892ac41 100644 --- a/quickstart/eino_assistant/cmd/einoagentcli/main.go +++ b/quickstart/eino_assistant/cmd/einoagentcli/main.go @@ -30,8 +30,6 @@ import ( "strconv" "strings" - "github.com/cloudwego/eino-ext/callbacks/langfuse" - "github.com/cloudwego/eino-ext/devops" "github.com/cloudwego/eino/callbacks" "github.com/cloudwego/eino/compose" "github.com/cloudwego/eino/schema" @@ -189,7 +187,7 @@ func RunAgent(ctx context.Context, id string, msg string) (*schema.StreamReader[ conversation.Append(fullMsg) }() - outter: + outer: for { select { case <-ctx.Done(): @@ -199,7 +197,7 @@ func RunAgent(ctx context.Context, id string, msg string) (*schema.StreamReader[ chunk, err := srs[1].Recv() if err != nil { if errors.Is(err, io.EOF) { - break outter + break outer } }