Возможно, я ошибаюсь, но похоже, что метод отмены в rq не работает. Моя задача выполняется
def example(seconds):
print('Starting task')
for i in range(seconds):
time.sleep(1)
print('Task completed')
, которую я начинаю использовать
job = queue.enqueue('app.tasks.example', 60)
Выполнение продолжается нормально после выполнения
job.cancel()
Версии: redis == 3.4.1, rq == 1.3.0