【Bug已解决】Feature request: Auto-resume paused Goals when quota refreshes 解决方案原始报错线索Feature request: Auto-resume paused Goals when quota refreshes希望「用量配额刷新后自动把被暂停的目标/任务恢复运行」而不是让用户手动去点。一、现象长什么样用户跑一个长任务目标 / Goal中途配额耗尽任务被自动暂停。之后配额在凌晨刷新了但任务一直停着没人通知、不自动恢复用户手动点「恢复」又能跑了——说明任务本身没问题只是「恢复动作」缺失有时用户自己点了恢复结果配额刷新检测又触发一次恢复任务被重复启动两次互相打架恢复后没记录「已恢复」配额再波动时又反复暂停/恢复状态抖动。 这本质是**「配额状态」与「任务调度状态」两个状态机没有联动**且恢复动作不具备幂等性。二、背景配额、暂停与恢复的状态模型2.1 配额Quota的常见形态周期性配额每天 / 每小时重置如「每日 100 次调用」容量配额总量固定消耗后需手动/自动补充速率配额单位时间令牌数令牌桶自然回满。 无论哪种关键是有一个「当前可用量」随时间变化的量。2.2 任务的四种状态RUNNING --配额耗尽-- PAUSED PAUSED --配额恢复-- RUNNING PAUSED --用户取消-- CANCELLED RUNNING --完成------ DONE「自动恢复」要做的就是监听「配额从不足变足」并把PAUSED推回RUNNING。2.3 为什么需要幂等配额可能在「刚好够 / 刚好不够」之间反复横跳检测逻辑可能一秒内触发多次「恢复」。若恢复动作不幂等就会拉起多个执行实例造成重复工作、双倍扣费、状态错乱。三、为什么不会自动恢复根因3.1 没有「配额变化 → 任务状态」的联动任务调度器和配额管理器是两套独立代码配额刷新时只更新了计数器没通知调度器去扫PAUSED任务。3.2 轮询太粗或太细太粗每小时一次配额刷新后最长要等一小时才恢复体验差太细每秒一次空转浪费资源。需要根据配额重置周期自适应。3.3 恢复不幂等多次触发恢复 → 多个实例。缺少「同一任务同一时刻只有一个 RUNNING」的约束。3.4 抖动flapping配额只在边界上下波动时任务在 PAUSED/RUNNING 间反复跳。需要加「恢复需配额超过阈值并稳定一段时间」的滞回hysteresis。四、最小可运行复现不幂等导致重复恢复下面演示「恢复动作无幂等保护」时多次检测触发双实例class SchedulerNaive: def __init__(self): self.task_state PAUSED def on_quota_refreshed(self): # 没有幂等检查只要检测到配额足就启动一次 if self.task_state PAUSED: self.task_state RUNNING print(启动任务实例) # 若被调用两次 - 两个实例 if __name__ __main__: s SchedulerNaive() # 配额检测在一次刷新中被触发两次例如两个定时器叠加 s.on_quota_refreshed() s.on_quota_refreshed() # 第二次仍会打印“启动任务实例”运行会打印两次「启动任务实例」——这就是重复恢复的 bug。五、解决方案一配额状态机 滞回用「滞回阈值」避免边界抖动且只有真正跨越阈值才改变判定class Quota: def __init__(self, used, limit): self.used used self.limit limit property def available(self): return self.limit - self.used def is_sufficient(self, resume_threshold: float 0.1) - bool: 可用量需超过上限的 10% 才算『足够』避免边界抖动。 return self.available self.limit * resume_threshold if __name__ __main__: q Quota(used95, limit100) print(是否足够恢复:, q.is_sufficient()) # False仅剩 5% q.used 80 print(是否足够恢复:, q.is_sufficient()) # True剩 20%resume_threshold提供滞回恢复要求「明显够用」不像暂停那样「一空就停」从而抑制 flapping。六、解决方案二幂等的恢复动作给任务加「正在恢复中」的中间态且用任务级锁保证同一时刻只有一个 RUNNING 实例from enum import Enum import threading class TaskState(Enum): RUNNING running PAUSED paused RESUMING resuming # 中间态防重入 CANCELLED cancelled class IdempotentScheduler: def __init__(self): self.state TaskState.PAUSED self._lock threading.Lock() def try_resume(self) - str: with self._lock: if self.state TaskState.RUNNING: return 已在运行跳过 if self.state TaskState.RESUMING: return 恢复中跳过重复触发 if self.state TaskState.CANCELLED: return 已取消不恢复 # 进入 RESUMING 中间态独占恢复流程 self.state TaskState.RESUMING # 此处真正启动执行体释放锁后再做重活避免持锁过久 try: self._start_executor() with self._lock: self.state TaskState.RUNNING return 恢复成功 except Exception: with self._lock: self.state TaskState.PAUSED # 失败回退 return 恢复失败回 PAUSED def _start_executor(self): print(真正启动执行体单实例) if __name__ __main__: s IdempotentScheduler() print(s.try_resume()) # 恢复成功 print(s.try_resume()) # 已在运行跳过不再双实例RESUMING中间态 锁确保多次配额刷新事件只会拉起一个执行体彻底消灭第四节的重复恢复。七、解决方案三把配额变化「通知」给调度器不要靠调度器盲轮询而是配额管理器在「跨过阈值」时主动回调事件驱动轮询只作兜底class QuotaManager: def __init__(self): self._was_sufficient False self._listeners [] def on_refresh(self, quota: Quota): now quota.is_sufficient() # 仅在 不足-足够 的上升沿触发恢复下降沿由任务自己暂停 if now and not self._was_sufficient: for cb in self._listeners: cb() self._was_sufficient now def subscribe(self, cb): self._listeners.append(cb) if __name__ __main__: sched IdempotentScheduler() qm QuotaManager() qm.subscribe(lambda: sched.try_resume()) # 配额恢复即自动恢复任务 qm.on_refresh(Quota(used95, limit100)) # 不足 - 不触发 qm.on_refresh(Quota(used80, limit100)) # 足够 - 触发恢复 qm.on_refresh(Quota(used78, limit100)) # 仍足够 - 不重复触发无上升沿上升沿触发是关键配额从「不够」变「够」才通知一次之后持续够也不再打扰——既及时又省资源。八、解决方案四自适应轮询兜底事件驱动之外加一个「根据配额重置周期自适应」的兜底轮询防止回调丢失import time def adaptive_poll(quota_getter, on_recover, reset_period_sec3600, jitter0.1): 在配额重置周期附近提高检查频率平时低频。 while True: q quota_getter() if q.is_sufficient(): on_recover() # 平时按周期 1/10 频率避免空转真实实现会结合「距下次重置的时间」 sleep max(30, reset_period_sec / 10) time.sleep(sleep * (1 jitter)) # 加抖动避免多实例共振要点轮询只是兜底主路径是上升沿事件频率随重置周期缩放并在多实例部署时加 jitter 防「惊群」。九、排查清单「配额刷新后任务不自动恢复」按下面排查配额刷新有没有通知调度器还是两套状态机各自为政恢复触发是上升沿还是持续轮询持续轮询易重复触发恢复动作幂等吗有没有「RESUMING 中间态 锁」防双实例有没有滞回阈值边界抖动会不会导致反复暂停/恢复失败回退对吗恢复失败是否回PAUSED而非卡在中间态轮询频率合理吗太粗恢复慢、太细空转是否按重置周期自适应用户手动恢复与自动恢复是否冲突两者走同一幂等入口状态可观测吗任务状态、上次恢复时间、触发原因是否可查。十、小结「配额刷新后不自动恢复暂停任务」的根因是配额状态机与任务调度状态机脱节且恢复动作不幂等。通用修复事件驱动 上升沿配额从「不足」跨到「足够」才通知一次第七节及时且不重复幂等恢复RESUMING中间态 任务级锁保证同一任务只有一个 RUNNING 实例第六节消灭重复恢复滞回阈值恢复要求「明显够用」而非「刚好够」抑制边界抖动第五节自适应兜底轮询主路径靠事件轮询按重置周期缩放 jitter 防惊群第八节。 一句话让配额状态的变化成为任务调度的输入用幂等和滞回把「自动恢复」做成既及时又不会抽风的能力。这与第 97 篇「升级后额度未重置」、第 110 篇「虚耗计费」共同指向一个主题——配额系统的状态必须被精确建模、精确联动、精确回退。
【Bug已解决】Feature request: Auto-resume paused Goals when quota refreshes 解决方案原始报错线索Feature request: Auto-resume paused Goals when quota refreshes希望「用量配额刷新后自动把被暂停的目标/任务恢复运行」而不是让用户手动去点。一、现象长什么样用户跑一个长任务目标 / Goal中途配额耗尽任务被自动暂停。之后配额在凌晨刷新了但任务一直停着没人通知、不自动恢复用户手动点「恢复」又能跑了——说明任务本身没问题只是「恢复动作」缺失有时用户自己点了恢复结果配额刷新检测又触发一次恢复任务被重复启动两次互相打架恢复后没记录「已恢复」配额再波动时又反复暂停/恢复状态抖动。 这本质是**「配额状态」与「任务调度状态」两个状态机没有联动**且恢复动作不具备幂等性。二、背景配额、暂停与恢复的状态模型2.1 配额Quota的常见形态周期性配额每天 / 每小时重置如「每日 100 次调用」容量配额总量固定消耗后需手动/自动补充速率配额单位时间令牌数令牌桶自然回满。 无论哪种关键是有一个「当前可用量」随时间变化的量。2.2 任务的四种状态RUNNING --配额耗尽-- PAUSED PAUSED --配额恢复-- RUNNING PAUSED --用户取消-- CANCELLED RUNNING --完成------ DONE「自动恢复」要做的就是监听「配额从不足变足」并把PAUSED推回RUNNING。2.3 为什么需要幂等配额可能在「刚好够 / 刚好不够」之间反复横跳检测逻辑可能一秒内触发多次「恢复」。若恢复动作不幂等就会拉起多个执行实例造成重复工作、双倍扣费、状态错乱。三、为什么不会自动恢复根因3.1 没有「配额变化 → 任务状态」的联动任务调度器和配额管理器是两套独立代码配额刷新时只更新了计数器没通知调度器去扫PAUSED任务。3.2 轮询太粗或太细太粗每小时一次配额刷新后最长要等一小时才恢复体验差太细每秒一次空转浪费资源。需要根据配额重置周期自适应。3.3 恢复不幂等多次触发恢复 → 多个实例。缺少「同一任务同一时刻只有一个 RUNNING」的约束。3.4 抖动flapping配额只在边界上下波动时任务在 PAUSED/RUNNING 间反复跳。需要加「恢复需配额超过阈值并稳定一段时间」的滞回hysteresis。四、最小可运行复现不幂等导致重复恢复下面演示「恢复动作无幂等保护」时多次检测触发双实例class SchedulerNaive: def __init__(self): self.task_state PAUSED def on_quota_refreshed(self): # 没有幂等检查只要检测到配额足就启动一次 if self.task_state PAUSED: self.task_state RUNNING print(启动任务实例) # 若被调用两次 - 两个实例 if __name__ __main__: s SchedulerNaive() # 配额检测在一次刷新中被触发两次例如两个定时器叠加 s.on_quota_refreshed() s.on_quota_refreshed() # 第二次仍会打印“启动任务实例”运行会打印两次「启动任务实例」——这就是重复恢复的 bug。五、解决方案一配额状态机 滞回用「滞回阈值」避免边界抖动且只有真正跨越阈值才改变判定class Quota: def __init__(self, used, limit): self.used used self.limit limit property def available(self): return self.limit - self.used def is_sufficient(self, resume_threshold: float 0.1) - bool: 可用量需超过上限的 10% 才算『足够』避免边界抖动。 return self.available self.limit * resume_threshold if __name__ __main__: q Quota(used95, limit100) print(是否足够恢复:, q.is_sufficient()) # False仅剩 5% q.used 80 print(是否足够恢复:, q.is_sufficient()) # True剩 20%resume_threshold提供滞回恢复要求「明显够用」不像暂停那样「一空就停」从而抑制 flapping。六、解决方案二幂等的恢复动作给任务加「正在恢复中」的中间态且用任务级锁保证同一时刻只有一个 RUNNING 实例from enum import Enum import threading class TaskState(Enum): RUNNING running PAUSED paused RESUMING resuming # 中间态防重入 CANCELLED cancelled class IdempotentScheduler: def __init__(self): self.state TaskState.PAUSED self._lock threading.Lock() def try_resume(self) - str: with self._lock: if self.state TaskState.RUNNING: return 已在运行跳过 if self.state TaskState.RESUMING: return 恢复中跳过重复触发 if self.state TaskState.CANCELLED: return 已取消不恢复 # 进入 RESUMING 中间态独占恢复流程 self.state TaskState.RESUMING # 此处真正启动执行体释放锁后再做重活避免持锁过久 try: self._start_executor() with self._lock: self.state TaskState.RUNNING return 恢复成功 except Exception: with self._lock: self.state TaskState.PAUSED # 失败回退 return 恢复失败回 PAUSED def _start_executor(self): print(真正启动执行体单实例) if __name__ __main__: s IdempotentScheduler() print(s.try_resume()) # 恢复成功 print(s.try_resume()) # 已在运行跳过不再双实例RESUMING中间态 锁确保多次配额刷新事件只会拉起一个执行体彻底消灭第四节的重复恢复。七、解决方案三把配额变化「通知」给调度器不要靠调度器盲轮询而是配额管理器在「跨过阈值」时主动回调事件驱动轮询只作兜底class QuotaManager: def __init__(self): self._was_sufficient False self._listeners [] def on_refresh(self, quota: Quota): now quota.is_sufficient() # 仅在 不足-足够 的上升沿触发恢复下降沿由任务自己暂停 if now and not self._was_sufficient: for cb in self._listeners: cb() self._was_sufficient now def subscribe(self, cb): self._listeners.append(cb) if __name__ __main__: sched IdempotentScheduler() qm QuotaManager() qm.subscribe(lambda: sched.try_resume()) # 配额恢复即自动恢复任务 qm.on_refresh(Quota(used95, limit100)) # 不足 - 不触发 qm.on_refresh(Quota(used80, limit100)) # 足够 - 触发恢复 qm.on_refresh(Quota(used78, limit100)) # 仍足够 - 不重复触发无上升沿上升沿触发是关键配额从「不够」变「够」才通知一次之后持续够也不再打扰——既及时又省资源。八、解决方案四自适应轮询兜底事件驱动之外加一个「根据配额重置周期自适应」的兜底轮询防止回调丢失import time def adaptive_poll(quota_getter, on_recover, reset_period_sec3600, jitter0.1): 在配额重置周期附近提高检查频率平时低频。 while True: q quota_getter() if q.is_sufficient(): on_recover() # 平时按周期 1/10 频率避免空转真实实现会结合「距下次重置的时间」 sleep max(30, reset_period_sec / 10) time.sleep(sleep * (1 jitter)) # 加抖动避免多实例共振要点轮询只是兜底主路径是上升沿事件频率随重置周期缩放并在多实例部署时加 jitter 防「惊群」。九、排查清单「配额刷新后任务不自动恢复」按下面排查配额刷新有没有通知调度器还是两套状态机各自为政恢复触发是上升沿还是持续轮询持续轮询易重复触发恢复动作幂等吗有没有「RESUMING 中间态 锁」防双实例有没有滞回阈值边界抖动会不会导致反复暂停/恢复失败回退对吗恢复失败是否回PAUSED而非卡在中间态轮询频率合理吗太粗恢复慢、太细空转是否按重置周期自适应用户手动恢复与自动恢复是否冲突两者走同一幂等入口状态可观测吗任务状态、上次恢复时间、触发原因是否可查。十、小结「配额刷新后不自动恢复暂停任务」的根因是配额状态机与任务调度状态机脱节且恢复动作不幂等。通用修复事件驱动 上升沿配额从「不足」跨到「足够」才通知一次第七节及时且不重复幂等恢复RESUMING中间态 任务级锁保证同一任务只有一个 RUNNING 实例第六节消灭重复恢复滞回阈值恢复要求「明显够用」而非「刚好够」抑制边界抖动第五节自适应兜底轮询主路径靠事件轮询按重置周期缩放 jitter 防惊群第八节。 一句话让配额状态的变化成为任务调度的输入用幂等和滞回把「自动恢复」做成既及时又不会抽风的能力。这与第 97 篇「升级后额度未重置」、第 110 篇「虚耗计费」共同指向一个主题——配额系统的状态必须被精确建模、精确联动、精确回退。
