Обновить задачу python-rq из рабочей функции

Я запускаю задачи Python-RQ, которые могут занять от нескольких минут до нескольких часов в зависимости от входных данных.

Я могу установить фиксированное время ожидания при планировании работы с помощью:

low = Queue('low', default_timeout=600)  # 10 mins
low.enqueue_call(really_really_slow, timeout=3600) # one hour

Можно ли продлить задачу python-rq из запущенных задач, когда время ожидания почти истекло? Например, когда время ожидания составляет 3600 секунд, а задание выполняется 3500 секунд?

Функция python, выполняемая на рабочем месте, разветвляет вызов подпроцесса для двоичного файла C++ и сообщает о своем прогрессе в ключ redis, поэтому теоретически она также может продлить работу в этом цикле, но я не знаю, как это сделать.

0 ответов

Другие вопросы по тегам