rqworker超时

Question

我正在使用django-rq来处理django站点上一些长期运行的任务。这些任务占用(我假设)rqworker的180秒超时时间：

JobTimeoutException: Job exceeded maximum timeout value (180 seconds).

如何增加这个超时值？我尝试在rqworker命令中添加--超时值360，但这是不被识别的。

在我的python代码中，我长期运行的工作称为

        django_rq.enqueue(
            populate_trends,
            self,
        )

已经试过了

        django_rq.enqueue_call(
            func=populate_trends,
            args=(self,),
            timeout=3600,
        )

我在rq docs中注意到了，但是django-rq似乎没有这样的方法。

更新

现在，我分了django-rq，并添加了一个placeholder fix来增加超时。可能需要与项目一起工作，以获得更长期的解决方案。我在那里启动了一个issue来讨论。

Answer 1

这似乎是解决问题的正确方法。

queue = django_rq.get_queue('default')
queue.enqueue(populate_trends, args=(self,), timeout=500) 

如果你需要传球，

queue = django_rq.get_queue('default')
queue.enqueue(populate_trends, args=(self,), kwargs={'x': 1,}, timeout=500) 

感谢django-rq项目中的selwin提供帮助。

Answer 2

更新:您可以将超时值参数作为关键字参数传递给django-rq的@作业装饰器。注意，您必须首先传递队列名参数。

@job("default", timeout=600)
def long_running_task():
    ...

Answer 3

使用job_timeout

queue.enqueue(worker_func, *args, **kwargs, job_timeout=200)

正如Stephen Blair所指出的，timeout参数不适用于新版本的rq：

timeout关于queue.enqueue()的论点已被否决，转而支持job_timeout。

https://github.com/rq/rq/blob/master/CHANGES.md#10-2019-04-06

其中，job_timeout具有与timeout相同的效果。