shoko/kugetsu
1
0
Fork 0
Code Issues 17 Pull Requests Actions Packages Projects Releases 3 Wiki Activity

fix(queue-daemon): implement timeout handling for long-running tasks #228

Merged
shoko merged 2 commits from fix/issue-166 into main 2026-04-08 04:51:54 +02:00
Conversation 3 Commits 2 Files Changed 1 +25
1 changed files with 25 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Showing only changes of commit 51ec844365 - Show all commits

25
skills/kugetsu/scripts/kugetsu-queue-daemon.sh
View File

@@ -41,6 +41,31 @@ check_task_completion() {
local session_id=$(python3 -c "import json; print(json.load(open('$item')).get('opencode_session_id', ''))" 2>/dev/null)
local issue_ref=$(python3 -c "import json; print(json.load(open('$item')).get('issue_ref', ''))" 2>/dev/null)
local pid=$(python3 -c "import json; print(json.load(open('$item')).get('pid', ''))" 2>/dev/null)
local notified_at=$(python3 -c "import json; print(json.load(open('$item')).get('notified_at', ''))" 2>/dev/null)
local timed_out=false
if [ -n "$notified_at" ]; then
local notified_epoch=$(date -d "$notified_at" +%s 2>/dev/null || echo "0")
local now_epoch=$(date +%s)
local hours_elapsed=$(( (now_epoch - notified_epoch) / 3600 ))
if [ "$hours_elapsed" -ge "${TASK_TIMEOUT_HOURS:-1}" ]; then
timed_out=true
echo "Task $queue_id ($issue_ref) timed out after ${hours_elapsed}h"
fi
fi
if [ "$timed_out" = true ]; then
if [ -n "$pid" ] && [ "$pid" != "None" ]; then
kill "$pid" 2>/dev/null || true
fi
if [ -n "$session_id" ]; then
opencode session stop "$session_id" 2>/dev/null || true
fi
update_queue_item_state "$queue_id" "error"
echo "Task $queue_id ($issue_ref) marked error — timeout after ${hours_elapsed}h"
han commented 2026-04-08 04:04:37 +02:00
Outdated
Review
Copy Link

for echo related stuff in this PR, I'd like to possibly use kugetsu-log rather than a raw echo so we can have a unified formatted log. what do you think?

for echo related stuff in this PR, I'd like to possibly use kugetsu-log rather than a raw echo so we can have a unified formatted log. what do you think?
release_lock "$issue_ref"
return
fi
if [ -n "$pid" ] && [ "$pid" != "None" ]; then
if ! kill -0 "$pid" 2>/dev/null; then