diff options
Diffstat (limited to 'Omni/Agent')
| -rw-r--r-- | Omni/Agent/WORKER_AGENT_GUIDE.md | 59 | ||||
| -rwxr-xr-x | Omni/Agent/harvest-tasks.sh | 55 | ||||
| -rwxr-xr-x | Omni/Agent/start-worker.sh | 60 |
3 files changed, 133 insertions, 41 deletions
diff --git a/Omni/Agent/WORKER_AGENT_GUIDE.md b/Omni/Agent/WORKER_AGENT_GUIDE.md index f1f6f60..64a55f8 100644 --- a/Omni/Agent/WORKER_AGENT_GUIDE.md +++ b/Omni/Agent/WORKER_AGENT_GUIDE.md @@ -64,38 +64,45 @@ task update t-123 in-progress ### Step 5: Submit for Review -```bash -# 1. Mark for review -task update t-123 review +1. **Commit Implementation**: + ```bash + git add . + git commit -m "feat: implement t-123" + ``` -# 2. Commit implementation -git add . -git commit -m "feat: implement t-123" +2. **Signal Review Readiness**: + The Planner checks the `omni-worker-X` branch for status updates. You must switch back and update the status there. -# 3. Switch back to worker base branch to prepare for next loop -# This detaches the worker from the task branch so the Planner can check it out -git checkout omni-worker-1 -./Omni/Agent/sync-tasks.sh -``` + ```bash + # Switch to base branch + git checkout omni-worker-1 + + # Sync to get latest state (and any manual merges) + ./Omni/Agent/sync-tasks.sh + + # Mark task for review + task update t-123 review + + # Commit this status change to the worker branch + ./Omni/Agent/sync-tasks.sh --commit + ``` + + *Note: The Planner will now see 't-123' in 'Review' when it runs `harvest-tasks.sh`.* ## 3. Planner (Reviewer) Workflow The Planner Agent (running in the main repo) will: -1. See tasks in `Review` status (after checking out the worker's branch or waiting for them to be merged). - * *Note: Since workers commit to local branches, you verify work by checking out their branch.* -2. Check out the worker's branch: `git checkout task/t-123`. -3. Review code and tests. -4. Merge to `live`: - ```bash - git checkout live - git merge task/t-123 - # Conflicts in tasks.jsonl are handled automatically by .gitattributes driver - ``` -5. Mark Done: - ```bash - task update t-123 done - git commit -am "task: t-123 done" - ``` +1. **Harvest Updates**: Run `./Omni/Agent/harvest-tasks.sh` to pull "In Progress" and "Review" statuses from workers. +2. **Find Reviews**: Run `task list --status=review`. +3. **Review Code**: + * Check out the feature branch: `git checkout task/t-123`. + * Run tests and review code. +4. **Merge**: + * `git checkout live` + * `git merge task/t-123` +5. **Complete**: + * `task update t-123 done` + * `git commit -am "task: t-123 done"` ## Troubleshooting diff --git a/Omni/Agent/harvest-tasks.sh b/Omni/Agent/harvest-tasks.sh new file mode 100755 index 0000000..282beab --- /dev/null +++ b/Omni/Agent/harvest-tasks.sh @@ -0,0 +1,55 @@ +#!/usr/bin/env bash +set -e + +# Omni/Agent/harvest-tasks.sh +# Imports task updates from all worker branches into the current branch (usually live). + +REPO_ROOT="$(git rev-parse --show-toplevel)" +cd "$REPO_ROOT" + +echo "Harvesting task updates from workers..." + +# Find all worker branches (assuming naming convention omni-worker-*) +# We filter for local branches +WORKER_BRANCHES=$(git branch --list "omni-worker-*" --format="%(refname:short)") + +if [ -z "$WORKER_BRANCHES" ]; then + echo "No worker branches found." + exit 0 +fi + +UPDATED=0 + +for branch in $WORKER_BRANCHES; do + echo "Checking $branch..." + + # Extract tasks.jsonl from the worker branch + if git show "$branch:.tasks/tasks.jsonl" > .tasks/worker-tasks.jsonl 2>/dev/null; then + # Import into current DB + # The import command handles deduplication and timestamp conflict resolution + if "$REPO_ROOT/_/bin/task" import -i .tasks/worker-tasks.jsonl >/dev/null; then + echo " Imported tasks from $branch" + UPDATED=1 + fi + else + echo " Warning: Could not read .tasks/tasks.jsonl from $branch" + fi +done + +rm -f .tasks/worker-tasks.jsonl + +if [ "$UPDATED" -eq 1 ]; then + # Consolidate + "$REPO_ROOT/_/bin/task" export --flush + + # Commit if there are changes + if [[ -n $(git status --porcelain .tasks/tasks.jsonl) ]]; then + git add .tasks/tasks.jsonl + git commit -m "task: harvest updates from workers" + echo "Success: Task database updated and committed." + else + echo "No effective changes found." + fi +else + echo "No updates found." +fi diff --git a/Omni/Agent/start-worker.sh b/Omni/Agent/start-worker.sh index 2c5eee4..e3a7200 100755 --- a/Omni/Agent/start-worker.sh +++ b/Omni/Agent/start-worker.sh @@ -2,18 +2,25 @@ set -e # Omni/Agent/start-worker.sh -# Launches an Amp worker agent in the specified worktree. -# Usage: ./Omni/Agent/start-worker.sh [worker-directory-name] +# Launches an Amp worker agent in the specified worktree in a loop. +# Usage: ./Omni/Agent/start-worker.sh [worker-directory-name-or-path] # Example: ./Omni/Agent/start-worker.sh omni-worker-1 -WORKER_NAME="${1:-omni-worker-1}" -REPO_ROOT="$(git rev-parse --show-toplevel)" -WORKER_PATH="$REPO_ROOT/../$WORKER_NAME" -AMP_BIN="$REPO_ROOT/node_modules/.bin/amp" +TARGET="${1:-omni-worker-1}" -if [ ! -d "$WORKER_PATH" ]; then - echo "Error: Worker directory '$WORKER_PATH' does not exist." - echo "Please run './Omni/Agent/setup-worker.sh $WORKER_NAME' first." +# 1. Find the Main Repo (where node_modules lives) +# The first worktree listed is always the main one +MAIN_REPO="$(git worktree list --porcelain | grep '^worktree ' | head -n 1 | cut -d ' ' -f 2)" +AMP_BIN="$MAIN_REPO/node_modules/.bin/amp" + +# 2. Resolve Worker Path +# If TARGET is a directory, use it. Otherwise assume it's a sibling of MAIN_REPO. +if [ -d "$TARGET" ]; then + WORKER_PATH="$(realpath "$TARGET")" +elif [ -d "$MAIN_REPO/../$TARGET" ]; then + WORKER_PATH="$(realpath "$MAIN_REPO/../$TARGET")" +else + echo "Error: Worker directory for '$TARGET' not found." exit 1 fi @@ -23,12 +30,35 @@ if [ ! -x "$AMP_BIN" ]; then exit 1 fi -echo "Starting Worker Agent in '$WORKER_PATH'..." -echo "Using Amp binary: $AMP_BIN" +echo "Starting Worker Agent Loop" +echo " Worker Path: $WORKER_PATH" +echo " Amp Binary: $AMP_BIN" +echo " Log File: $WORKER_PATH/_/llm/amp.log" +echo " Monitor: tail -f $WORKER_PATH/_/llm/amp.log" +echo " Press Ctrl+C to stop." cd "$WORKER_PATH" -# Launch Amp with the worker persona and instructions -"$AMP_BIN" -- "You are a Worker Agent. Your goal is to process tasks from the task manager. -Please read Omni/Agent/WORKER_AGENT_GUIDE.md and follow the 'Worker Loop' instructions exactly. -Start by syncing tasks and checking for ready work." +# 3. The Worker Loop +while true; do + echo "----------------------------------------------------------------" + echo "$(date): Starting new agent session..." + + mkdir -p _/llm + "$AMP_BIN" --log-file "_/llm/amp.log" --dangerously-allow-all -x "You are a Worker Agent. Your goal is to process tasks from the task manager. + + Step 1: Read 'Omni/Agent/WORKER_AGENT_GUIDE.md' to understand your workflow. + Step 2: Follow the 'Worker Loop' instructions exactly. + + Start by syncing tasks and checking for ready work. If no work is ready, exit." + + EXIT_CODE=$? + + if [ $EXIT_CODE -ne 0 ]; then + echo "Agent exited with error code $EXIT_CODE. Sleeping for 10s..." + sleep 10 + else + echo "Agent session finished. Sleeping for 5s..." + sleep 5 + fi +done |