Compare commits
1 Commits
fix/issue-
...
fix/issue-
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
9f7da84915 |
@@ -364,14 +364,10 @@ kugetsu queue-daemon logs # Show recent daemon logs
|
|||||||
|
|
||||||
**Daemon Behavior:**
|
**Daemon Behavior:**
|
||||||
1. Runs at configurable interval (default: 5 minutes)
|
1. Runs at configurable interval (default: 5 minutes)
|
||||||
2. Checks queue for pending items
|
2. Checks if active agents < MAX_CONCURRENT_AGENTS
|
||||||
3. For each pending item:
|
3. Picks 1-N pending items (configurable batch size)
|
||||||
- Acquires lock to prevent duplicate processing
|
4. Forks PM session for each picked item
|
||||||
- Sources kugetsu-session.sh and calls `cmd_continue`
|
5. PM decides whether to use `start` or `continue`
|
||||||
- `cmd_continue` handles worktree/session creation and forks dev agent from base session
|
|
||||||
- Updates queue item state to "notified"
|
|
||||||
4. Uses per-issue locking to prevent race conditions
|
|
||||||
5. Implements timeout for tasks that don't complete (marks as "error" after TASK_TIMEOUT_HOURS)
|
|
||||||
|
|
||||||
**Queue Directory:**
|
**Queue Directory:**
|
||||||
```
|
```
|
||||||
@@ -530,13 +526,6 @@ The script will:
|
|||||||
|
|
||||||
See [docs/kugetsu-setup.md](../../docs/kugetsu-setup.md) for full Tailscale setup documentation.
|
See [docs/kugetsu-setup.md](../../docs/kugetsu-setup.md) for full Tailscale setup documentation.
|
||||||
|
|
||||||
## Version History
|
|
||||||
|
|
||||||
### v0.2.3
|
|
||||||
- **Queue daemon context drift fix** (issue #156): Daemon now sources kugetsu-session.sh and calls `cmd_continue` directly instead of forking PM session. This fixes context drift where daemon would lose track of task state.
|
|
||||||
- **Daemon locking**: Added per-issue locking to prevent race conditions when multiple daemon instances run.
|
|
||||||
- **Timeout handling**: Tasks that don't complete within TASK_TIMEOUT_HOURS are marked as "error".
|
|
||||||
|
|
||||||
## Without kugetsu
|
## Without kugetsu
|
||||||
|
|
||||||
If kugetsu is not available, use opencode directly:
|
If kugetsu is not available, use opencode directly:
|
||||||
|
|||||||
@@ -17,77 +17,122 @@ usage() {
|
|||||||
kugetsu - OpenCode Session Manager (Issue-Driven)
|
kugetsu - OpenCode Session Manager (Issue-Driven)
|
||||||
|
|
||||||
Usage:
|
Usage:
|
||||||
kugetsu init [--force] Initialize base + pm-agent sessions (requires TTY)
|
kugetsu <command> [subcommand] [options]
|
||||||
kugetsu start <issue-ref> <message> [--debug] Start task for issue (forks base session)
|
|
||||||
kugetsu continue <issue-ref> [message] [--debug] Continue existing task for issue
|
Commands:
|
||||||
kugetsu delegate <message> Send message to PM agent (fire-and-forget)
|
init [--force] Initialize base + pm-agent sessions (requires TTY)
|
||||||
kugetsu logs [n] Show recent delegation logs (default: 10)
|
start <issue-ref> <message> [--debug] Start task for issue (forks base session)
|
||||||
kugetsu status Check kugetsu initialization status
|
continue <issue-ref> [message] [--debug] Continue existing task for issue
|
||||||
kugetsu doctor [--fix] Diagnose and fix kugetsu issues
|
delegate <message> Send message to PM agent (fire-and-forget)
|
||||||
kugetsu notify [list|clear] Show or clear notifications
|
logs [n] Show recent delegation logs (default: 10)
|
||||||
kugetsu list List all tracked sessions
|
status Check kugetsu initialization status
|
||||||
kugetsu prune [--force] Remove orphaned sessions (keeps base + pm-agent)
|
doctor [--fix] Diagnose and fix kugetsu issues
|
||||||
kugetsu destroy <issue-ref> [-y] Delete session for issue
|
notify [list|clear] Show or clear notifications
|
||||||
kugetsu destroy --pm-agent [-y] Delete pm-agent session (not recommended)
|
list List all tracked sessions
|
||||||
kugetsu destroy --base [-y] Delete base session
|
prune [--force] Remove orphaned sessions
|
||||||
kugetsu set-pr <issue-ref> <pr-url> Set PR URL for session (for PR tracking)
|
destroy <target> [-y] Delete session (issue, pm-agent, or base)
|
||||||
kugetsu context <issue-ref> Show context for issue
|
set-pr <issue-ref> <pr-url> Set PR URL for session
|
||||||
kugetsu queue [list|stats|clear] Show queue status or statistics
|
context <issue-ref> Show context for issue
|
||||||
kugetsu queue enqueue <issue-ref> <message> Enqueue a task (normally via delegate)
|
queue [subcommand] Queue management
|
||||||
kugetsu queue-daemon [start|stop|restart|status|logs] Manage queue daemon
|
queue-daemon [subcommand] Queue daemon management
|
||||||
kugetsu env [get|set|list] Manage agent environment variables
|
env [subcommand] Environment variable management
|
||||||
kugetsu server [list|add|remove|default|get] Manage git server configurations
|
server [subcommand] Git server configuration
|
||||||
kugetsu help Show this help
|
help [command] Show help for a command
|
||||||
|
|
||||||
|
Use 'kugetsu <command> help' for subcommand help.
|
||||||
|
Example: kugetsu queue help, kugetsu queue-daemon help
|
||||||
|
|
||||||
Issue Ref Format:
|
Issue Ref Format:
|
||||||
instance/user/repo#number
|
instance/user/repo#number
|
||||||
Example: github.com/shoko/kugetsu#14
|
Example: github.com/shoko/kugetsu#14
|
||||||
|
EOF
|
||||||
|
}
|
||||||
|
|
||||||
Commands:
|
usage_queue() {
|
||||||
init Create base + pm-agent sessions via TUI. Requires terminal access.
|
cat << 'EOF'
|
||||||
Use --force to reinitialize if sessions exist.
|
kugetsu queue - Queue management
|
||||||
start Fork new session from base for specific issue.
|
|
||||||
Requires pm-agent to be running (created by init).
|
|
||||||
continue Continue work on existing issue session.
|
|
||||||
delegate Send message to PM agent for task coordination.
|
|
||||||
Fire-and-forget: returns immediately, runs in background.
|
|
||||||
Use 'kugetsu logs' to check output.
|
|
||||||
logs Show recent delegation logs.
|
|
||||||
Default: 10 most recent. Use 'kugetsu logs 20' for more.
|
|
||||||
status Check if kugetsu is initialized and PM agent is active.
|
|
||||||
doctor Diagnose kugetsu issues. Use --fix to attempt repairs.
|
|
||||||
notify Show or clear notifications from PM agent.
|
|
||||||
Use 'kugetsu notify list' to see unread notifications.
|
|
||||||
list Show all sessions (base + pm-agent + forked issues).
|
|
||||||
prune Remove sessions not in index (orphaned from opencode).
|
|
||||||
Use --force to skip confirmation.
|
|
||||||
destroy Delete specific issue, pm-agent, or base session.
|
|
||||||
|
|
||||||
Options:
|
Usage:
|
||||||
--debug Show real-time debug output and capture to debug.log
|
kugetsu queue [subcommand]
|
||||||
|
|
||||||
PM Context:
|
Subcommands:
|
||||||
kugetsu reads ~/.kugetsu/pm-agent.md (if exists) and injects it
|
list Show pending tasks (default)
|
||||||
into the PM agent session at init time. This allows customizing PM
|
stats Show queue statistics
|
||||||
behavior without recreating the session.
|
clear Clear all queue items
|
||||||
|
enqueue <issue-ref> <message> Enqueue a task
|
||||||
Notifications:
|
help Show this help
|
||||||
PM Agent writes task completion notifications to ~/.kugetsu/notifications.json
|
|
||||||
Use 'kugetsu notify list' to see unread notifications.
|
|
||||||
|
|
||||||
Examples:
|
Examples:
|
||||||
kugetsu init
|
kugetsu queue list
|
||||||
kugetsu status
|
kugetsu queue stats
|
||||||
kugetsu delegate "work on issue #5"
|
kugetsu queue clear
|
||||||
kugetsu logs
|
kugetsu queue enqueue github.com/shoko/kugetsu#14 "fix bug"
|
||||||
kugetsu logs 20
|
EOF
|
||||||
kugetsu doctor
|
}
|
||||||
kugetsu doctor --fix
|
|
||||||
kugetsu notify list
|
usage_queue_daemon() {
|
||||||
kugetsu notify clear
|
cat << 'EOF'
|
||||||
kugetsu start github.com/shoko/kugetsu#14 "fix bug"
|
kugetsu queue-daemon - Queue daemon management
|
||||||
kugetsu continue github.com/shoko/kugetsu#14 "add tests"
|
|
||||||
kugetsu list
|
Usage:
|
||||||
|
kugetsu queue-daemon [subcommand]
|
||||||
|
|
||||||
|
Subcommands:
|
||||||
|
start Start the queue daemon
|
||||||
|
stop Stop the queue daemon
|
||||||
|
restart Restart the queue daemon
|
||||||
|
status Check daemon status
|
||||||
|
logs Show recent daemon logs
|
||||||
|
help Show this help
|
||||||
|
|
||||||
|
Examples:
|
||||||
|
kugetsu queue-daemon start
|
||||||
|
kugetsu queue-daemon status
|
||||||
|
kugetsu queue-daemon logs
|
||||||
|
EOF
|
||||||
|
}
|
||||||
|
|
||||||
|
usage_env() {
|
||||||
|
cat << 'EOF'
|
||||||
|
kugetsu env - Environment variable management
|
||||||
|
|
||||||
|
Usage:
|
||||||
|
kugetsu env [subcommand]
|
||||||
|
|
||||||
|
Subcommands:
|
||||||
|
list List all environment variables
|
||||||
|
get <key> Get a specific variable
|
||||||
|
set <key> <value> Set a variable
|
||||||
|
rm <key> Remove a variable
|
||||||
|
help Show this help
|
||||||
|
|
||||||
|
Examples:
|
||||||
|
kugetsu env list
|
||||||
|
kugetsu env get GITEA_TOKEN
|
||||||
|
kugetsu env set CUSTOM_VAR "value"
|
||||||
|
kugetsu env rm CUSTOM_VAR
|
||||||
|
EOF
|
||||||
|
}
|
||||||
|
|
||||||
|
usage_server() {
|
||||||
|
cat << 'EOF'
|
||||||
|
kugetsu server - Git server configuration
|
||||||
|
|
||||||
|
Usage:
|
||||||
|
kugetsu server [subcommand]
|
||||||
|
|
||||||
|
Subcommands:
|
||||||
|
list List all configured servers (default)
|
||||||
|
add <name> <url> Add a new server
|
||||||
|
remove <name> Remove a server
|
||||||
|
default [<name>] Get or set default server
|
||||||
|
get [<name>] Get server URL
|
||||||
|
help Show this help
|
||||||
|
|
||||||
|
Examples:
|
||||||
|
kugetsu server list
|
||||||
|
kugetsu server add github.com https://github.com
|
||||||
|
kugetsu server default github.com
|
||||||
EOF
|
EOF
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -865,10 +910,15 @@ find_sessions_by_issue_number() {
|
|||||||
}
|
}
|
||||||
|
|
||||||
cmd_queue() {
|
cmd_queue() {
|
||||||
local action="${1:-list}"
|
local action="${1:-}"
|
||||||
shift
|
|
||||||
|
|
||||||
case "$action" in
|
case "$action" in
|
||||||
|
""|help|--help|-h)
|
||||||
|
usage_queue
|
||||||
|
;;
|
||||||
|
help|--help|-h)
|
||||||
|
usage_queue
|
||||||
|
;;
|
||||||
list)
|
list)
|
||||||
local pending_tasks=$(get_pending_tasks 10)
|
local pending_tasks=$(get_pending_tasks 10)
|
||||||
if [ "$pending_tasks" = "[]" ]; then
|
if [ "$pending_tasks" = "[]" ]; then
|
||||||
@@ -898,8 +948,8 @@ cmd_queue() {
|
|||||||
echo "Queue cleared."
|
echo "Queue cleared."
|
||||||
;;
|
;;
|
||||||
enqueue)
|
enqueue)
|
||||||
local issue_ref="${1:-}"
|
local issue_ref="${2:-}"
|
||||||
local message="${2:-}"
|
local message="${3:-}"
|
||||||
if [ -z "$issue_ref" ] || [ -z "$message" ]; then
|
if [ -z "$issue_ref" ] || [ -z "$message" ]; then
|
||||||
echo "Usage: kugetsu queue enqueue <issue-ref> <message>" >&2
|
echo "Usage: kugetsu queue enqueue <issue-ref> <message>" >&2
|
||||||
exit 1
|
exit 1
|
||||||
@@ -910,16 +960,20 @@ cmd_queue() {
|
|||||||
check_task_timeouts
|
check_task_timeouts
|
||||||
;;
|
;;
|
||||||
*)
|
*)
|
||||||
echo "Usage: kugetsu queue [list|stats|clear|enqueue]" >&2
|
echo "Unknown queue subcommand: $action" >&2
|
||||||
|
usage_queue
|
||||||
exit 1
|
exit 1
|
||||||
;;
|
;;
|
||||||
esac
|
esac
|
||||||
}
|
}
|
||||||
|
|
||||||
cmd_queue_daemon() {
|
cmd_queue_daemon() {
|
||||||
local action="${1:-status}"
|
local action="${1:-}"
|
||||||
|
|
||||||
case "$action" in
|
case "$action" in
|
||||||
|
""|help|--help|-h)
|
||||||
|
usage_queue_daemon
|
||||||
|
;;
|
||||||
start)
|
start)
|
||||||
if [ -f "$QUEUE_DAEMON_PID_FILE" ]; then
|
if [ -f "$QUEUE_DAEMON_PID_FILE" ]; then
|
||||||
local old_pid=$(cat "$QUEUE_DAEMON_PID_FILE")
|
local old_pid=$(cat "$QUEUE_DAEMON_PID_FILE")
|
||||||
@@ -978,7 +1032,8 @@ cmd_queue_daemon() {
|
|||||||
fi
|
fi
|
||||||
;;
|
;;
|
||||||
*)
|
*)
|
||||||
echo "Usage: kugetsu queue-daemon [start|stop|restart|status|logs]" >&2
|
echo "Unknown queue-daemon subcommand: $action" >&2
|
||||||
|
usage_queue_daemon
|
||||||
exit 1
|
exit 1
|
||||||
;;
|
;;
|
||||||
esac
|
esac
|
||||||
@@ -1059,10 +1114,12 @@ set_debug_mode() {
|
|||||||
}
|
}
|
||||||
|
|
||||||
cmd_env() {
|
cmd_env() {
|
||||||
local action="${1:-list}"
|
local action="${1:-}"
|
||||||
shift
|
|
||||||
|
|
||||||
case "$action" in
|
case "$action" in
|
||||||
|
""|help|--help|-h)
|
||||||
|
usage_env
|
||||||
|
;;
|
||||||
list)
|
list)
|
||||||
echo "Agent environment variables:"
|
echo "Agent environment variables:"
|
||||||
if [ -d "$ENV_DIR" ]; then
|
if [ -d "$ENV_DIR" ]; then
|
||||||
@@ -1080,7 +1137,7 @@ cmd_env() {
|
|||||||
fi
|
fi
|
||||||
;;
|
;;
|
||||||
get)
|
get)
|
||||||
local key="${1:-}"
|
local key="${2:-}"
|
||||||
if [ -z "$key" ]; then
|
if [ -z "$key" ]; then
|
||||||
echo "Usage: kugetsu env get <key>" >&2
|
echo "Usage: kugetsu env get <key>" >&2
|
||||||
exit 1
|
exit 1
|
||||||
@@ -1095,8 +1152,8 @@ cmd_env() {
|
|||||||
fi
|
fi
|
||||||
;;
|
;;
|
||||||
set)
|
set)
|
||||||
local key="${1:-}"
|
local key="${2:-}"
|
||||||
local value="${2:-}"
|
local value="${3:-}"
|
||||||
if [ -z "$key" ] || [ -z "$value" ]; then
|
if [ -z "$key" ] || [ -z "$value" ]; then
|
||||||
echo "Usage: kugetsu env set <key> <value>" >&2
|
echo "Usage: kugetsu env set <key> <value>" >&2
|
||||||
exit 1
|
exit 1
|
||||||
@@ -1105,8 +1162,8 @@ cmd_env() {
|
|||||||
echo "${key}=${value}" >> "$ENV_DIR/default.env"
|
echo "${key}=${value}" >> "$ENV_DIR/default.env"
|
||||||
echo "Set $key in $ENV_DIR/default.env"
|
echo "Set $key in $ENV_DIR/default.env"
|
||||||
;;
|
;;
|
||||||
rm)
|
rm|remove)
|
||||||
local key="${1:-}"
|
local key="${2:-}"
|
||||||
if [ -z "$key" ]; then
|
if [ -z "$key" ]; then
|
||||||
echo "Usage: kugetsu env rm <key>" >&2
|
echo "Usage: kugetsu env rm <key>" >&2
|
||||||
exit 1
|
exit 1
|
||||||
@@ -1117,7 +1174,8 @@ cmd_env() {
|
|||||||
fi
|
fi
|
||||||
;;
|
;;
|
||||||
*)
|
*)
|
||||||
echo "Usage: kugetsu env [list|get|set|rm]" >&2
|
echo "Unknown env subcommand: $action" >&2
|
||||||
|
usage_env
|
||||||
exit 1
|
exit 1
|
||||||
;;
|
;;
|
||||||
esac
|
esac
|
||||||
@@ -1127,7 +1185,10 @@ cmd_server() {
|
|||||||
local action="${1:-}"
|
local action="${1:-}"
|
||||||
|
|
||||||
case "$action" in
|
case "$action" in
|
||||||
""|"list")
|
""|help|--help|-h)
|
||||||
|
usage_server
|
||||||
|
;;
|
||||||
|
"list")
|
||||||
if [ -z "${GIT_SERVERS+x}" ]; then
|
if [ -z "${GIT_SERVERS+x}" ]; then
|
||||||
echo "No git servers configured"
|
echo "No git servers configured"
|
||||||
return
|
return
|
||||||
@@ -1204,14 +1265,8 @@ cmd_server() {
|
|||||||
fi
|
fi
|
||||||
;;
|
;;
|
||||||
*)
|
*)
|
||||||
echo "Usage: kugetsu server <list|add|remove|default|get>" >&2
|
echo "Unknown server subcommand: $action" >&2
|
||||||
echo "" >&2
|
usage_server
|
||||||
echo "Commands:" >&2
|
|
||||||
echo " list List all configured git servers" >&2
|
|
||||||
echo " add <name> <url> Add a new git server" >&2
|
|
||||||
echo " remove <name> Remove a git server" >&2
|
|
||||||
echo " default [<name>] Get or set default server" >&2
|
|
||||||
echo " get [<name>] Get URL for a server (default: current default)" >&2
|
|
||||||
exit 1
|
exit 1
|
||||||
;;
|
;;
|
||||||
esac
|
esac
|
||||||
@@ -1321,7 +1376,29 @@ main() {
|
|||||||
|
|
||||||
case "$command" in
|
case "$command" in
|
||||||
help|--help|-h)
|
help|--help|-h)
|
||||||
usage
|
local subcommand="${1:-}"
|
||||||
|
case "$subcommand" in
|
||||||
|
queue|"")
|
||||||
|
usage_queue
|
||||||
|
;;
|
||||||
|
queue-daemon)
|
||||||
|
usage_queue_daemon
|
||||||
|
;;
|
||||||
|
env)
|
||||||
|
usage_env
|
||||||
|
;;
|
||||||
|
server)
|
||||||
|
usage_server
|
||||||
|
;;
|
||||||
|
"")
|
||||||
|
usage
|
||||||
|
;;
|
||||||
|
*)
|
||||||
|
echo "Help not available for '$subcommand'" >&2
|
||||||
|
usage
|
||||||
|
exit 1
|
||||||
|
;;
|
||||||
|
esac
|
||||||
;;
|
;;
|
||||||
init)
|
init)
|
||||||
cmd_init "$@"
|
cmd_init "$@"
|
||||||
|
|||||||
Reference in New Issue
Block a user