python-rq作业无超时

Question

有没有办法为worker指定"maximum“= inf超时？我有一些长时间运行的任务，如果由于超时而失败，我会在worker内部处理它。

可以通过cli指定这一点吗？

Answer 1

超时参数指定任务在被认为“丢失”之前的最大运行时间。可以与@job，Queue，enqueue & enqueue_call一起使用。

from rq.decorators import job

@job('low', connection=my_redis_conn, timeout=600)
def long_running_task(x, y):
    # Code

python-rq.org/docs

Answer 2

设置Queue(default_timeout=-1)就可以了。以下是它们的源代码的引用：

    def create_job(self, func, args=None, kwargs=None, timeout=None,
               result_ttl=None, ttl=None, failure_ttl=None,
               description=None, depends_on=None, job_id=None,
               meta=None, status=JobStatus.QUEUED, retry=None):
    """Creates a job based on parameters given."""
    timeout = parse_timeout(timeout)

    if timeout is None:
        timeout = self._default_timeout
    elif timeout == 0:
        raise ValueError('0 timeout is not allowed. Use -1 for infinite timeout')