Skip to content

Commit

Permalink
fix: word typo
Browse files Browse the repository at this point in the history
  • Loading branch information
BytePender committed Jan 20, 2025
1 parent 06b989d commit f654397
Show file tree
Hide file tree
Showing 3 changed files with 11 additions and 13 deletions.
10 changes: 5 additions & 5 deletions quickstart/eino_assistant/cmd/einoagent/agent/agent.go
Original file line number Diff line number Diff line change
Expand Up @@ -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()
Expand Down Expand Up @@ -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():
Expand All @@ -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
}
}

Expand Down
8 changes: 4 additions & 4 deletions quickstart/eino_assistant/cmd/einoagent/agent/server.go
Original file line number Diff line number Diff line change
Expand Up @@ -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():
Expand All @@ -126,19 +126,19 @@ 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{
Data: []byte(msg.Content),
})
if err != nil {
log.Printf("[Chat] Error publishing message: %v\n", err)
break outter
break outer
}
}
}
Expand Down
6 changes: 2 additions & 4 deletions quickstart/eino_assistant/cmd/einoagentcli/main.go
Original file line number Diff line number Diff line change
Expand Up @@ -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"
Expand Down Expand Up @@ -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():
Expand All @@ -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
}
}

Expand Down

0 comments on commit f654397

Please sign in to comment.