diff --git a/src/daemon/ticker.py b/src/daemon/ticker.py index 38880ba..3537384 100644 --- a/src/daemon/ticker.py +++ b/src/daemon/ticker.py @@ -675,9 +675,15 @@ class Ticker: "elapsed_minutes": round(elapsed, 1)}, ) if ok: + # 递增 retry_count(复用为广播轮次计数) + conn.execute( + "UPDATE tasks SET retry_count = COALESCE(retry_count, 0) + 1 WHERE id=?", + (task.id,), + ) + conn.commit() reclaimed.append(task.id) - logger.info("Reclaimed %s: claimed → pending (timeout %.1fm)", - task.id, elapsed) + logger.info("Reclaimed %s: claimed → pending (timeout %.1fm, retry=%d)", + task.id, elapsed, retry_count + 1) finally: conn.close() except (ValueError, TypeError):