auto-sync: 2026-05-21 11:54:01

2026-05-21 11:54:01 +08:00
parent 9559f138ba
commit a60813c3b5
1 changed files with 8 additions and 2 deletions
@@ -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):