search

ydf0509 / funboost

pip install funboost，python全功能分布式函数调度框架,funboost的功能是全面性重量级，用户能想得到的功能99%全都有;funboost的使用方式是轻量级，只有@boost一行代码需要写。支持python所有类型的并发模式和一切知名消息队列中间件，支持如 celery dramatiq等框架整体作为funboost中间件，python函数加速器，框架包罗万象，用户能想到的控制功能全都有。一统编程思维，兼容50% python业务场景，适用范围广。只需要一行代码即可分布式执行python一切函数，99%用过funboost的pythoner 感受是　简易 方便 强劲 强大，相见恨晚 。
Apache License 2.0
682 stars 135 forks source link

delay 任务支持retry的时候设置countdown吗？ #101

Closed imerse closed 9 months ago

imerse commented 9 months ago 
@boost(BoosterParams(queue_name='test_delay2', broker_kind=BrokerEnum.REDIS, qps=10, concurrent_mode=ConcurrentModeEnum.THREADING, 
       max_retry_times=2,))
def f(x):
    print(x)
    time.sleep(5)
    print(x)
    raise Exception('模拟消费函数可能出错')

请问，可以在设置重试的时间间隔吗？而不是立即重试？貌似没看到这个参数设置，用time.sleep()模拟？

ydf0509 commented 9 months ago

目前是立即重试,框架没有提间隔多少秒后再重试

ydf0509 commented 9 months ago

你升级到41.4的最新版本,现在新加了入参, retry_interval image

ydf0509 commented 9 months ago

pip install funboost==41.4 --upgrade -i https://pypi.org/simple

新增了可以设置多少秒再重试运行函数