小编Vic*_*hat的帖子

Celery:为某些任务分配特定的时间限制

我有一个这样写的任务:

@async_runner.app.task(name='task_name')
def async_task():
    async_runner.send_task(
        task_fn=task_processing,
        queue='queue_name',
        options=async_runner.DEFAULT_RETRY_POLICY
    )
Run Code Online (Sandbox Code Playgroud)

我的默认任务时间限制是 30 分钟。我想将此特定任务的时间限制增加到 1 小时。

如何为这一项任务设置不同的时间限制?

我已经看过这个,但我的问题是特定于 Flask 以及如何在 Flask 中配置 Celery。谢谢。

python celery

0
推荐指数
1
解决办法
1715
查看次数

标签 统计

celery ×1

python ×1