Concurrent Runs

# local runtime (default)
go run ./agent_with_concurrent_runs

# pass your own prompts
go run ./agent_with_concurrent_runs "Who wrote Hamlet?" "What is sqrt(144)?" "Name a primary color."

# Temporal
task infra:temporal:up && task infra:temporal:wait
AGENT_RUNTIME=temporal go run ./agent_with_concurrent_runs

# Restate
task infra:restate:up && task infra:restate:wait
AGENT_RUNTIME=restate go run ./agent_with_concurrent_runs

a, _ := agent.NewAgent(
    agent.WithName("concurrent-agent"),
    agent.WithLLMClient(llmClient),
    // ...same options for local, Temporal, or Restate
)

var wg sync.WaitGroup
resultCh := make(chan result, len(prompts))

for i, prompt := range prompts {
    wg.Add(1)
    go func(idx int, p string) {
        defer wg.Done()
        agentRun, err := a.Run(context.Background(), p, nil)
        if err != nil {
            resultCh <- result{idx: idx, prompt: p, err: err}
            return
        }
        res, getErr := agentRun.Get(context.Background())
        resultCh <- result{idx: idx, prompt: p, res: res, err: getErr}
    }(i, prompt)
}

go func() { wg.Wait(); close(resultCh) }()

for r := range resultCh {
    fmt.Printf("Q: %s\nA: %s\n\n", r.prompt, r.res.Content)
}

Q: Who wrote Hamlet?
A: Hamlet was written by William Shakespeare.

Q: What is sqrt(144)?
A: The square root of 144 is 12.

Q: Name a primary color.
A: Red is a primary color.