Open yiliangxiajiao opened 3 months ago
很好的建议,不过2不会考虑。 2的应用场景非常少,几乎不存在,
我读了很多遍,感觉是泛谈。 你的目标是解决异常导致计数重置问题,不应该引入新的东东。 当下计数最大一般伴随一个限时最大,这个两个已经够用了,而且现有的对用户暴露的选项已经够多了。 在Alas体系下一个任务是否执行只有一个指标next_run,否则就是在堆屎。
我之前想的是,需要计数的任务多一个字段写到配置文件去(pydantic可以做到隐藏),现在引入一个全局的也是不错
你说的有道理,我想一下怎么实现比较优雅
当前不足
考虑以下情景:
在现有调度器下,2无法实现,1可以实现,但是现在的计数器是基于任务的,如果遇到特殊情况,如程序崩溃、人为中断,计数器就会重置。
解决方案
考虑引入全局计数器机制,计数器分为次数计数器和物品计数器:
计数器可配置时间限定,可有以下选择:
计数器配置完成后可作为任务的参数,决定任务是否启动