Run many agents in parallel

source=bx_f7k2q9hd
tasks=("Fix issue 101" "Fix issue 102" "Fix issue 103" "Fix issue 104")

for task in "${tasks[@]}"; do
  id=$(boat fork "$source" --ttl 7200 --json | jq -r .id)
  echo "$id" >> forks.txt
  boat prompt "$id" "$task" > "$id.log" 2>&1 &   # runs in the background
  sleep 6                                         # stay under the start limit
done
wait                                              # every agent is done

import os, time, uuid
from boat_sdk import ApiClient, Configuration, wait_until_ready, wait_for_prompt
from boat_sdk.api.boat_api import BoatApi
from boat_sdk.exceptions import ApiException
from boat_sdk.models.fork_request import ForkRequest
from boat_sdk.models.prompt_request import PromptRequest

config = Configuration(host="https://boat.dev/api/v1", access_token=os.environ["BOAT_API_KEY"])
source = "bx_f7k2q9hd"
tasks = ["Fix issue 101", "Fix issue 102", "Fix issue 103", "Fix issue 104"]

with ApiClient(config) as client:
    sandbox = BoatApi(client)
    runs = []
    for task in tasks:
        key = str(uuid.uuid4())   # the same key on a retry never makes a second fork
        while True:
            try:
                forked = sandbox.fork(
                    sandbox_id=source,
                    fork_request=ForkRequest(ttl_seconds=7200),
                    idempotency_key=key,
                )
                break
            except ApiException as exc:
                if exc.status != 429:
                    raise
                time.sleep(10)    # start limit hit: wait, then retry with the same key
        wait_until_ready(sandbox, forked.id)
        queued = sandbox.prompt(forked.id, PromptRequest(prompt=task))
        runs.append((forked.id, queued.prompt_id))
        time.sleep(6)             # stay under the start limit

    for sandbox_id, prompt_id in runs:
        run = wait_for_prompt(sandbox, sandbox_id, prompt_id)
        print(sandbox_id, run.status)