chore(rq): Pass rq.Callback objects to enqueue_call (#22271)

> DeprecationWarning: Passing a string or function for `on_failure` is deprecated, pass `Callback` instead
This commit is contained in:
Corentin Flr 2023-09-02 07:52:33 +02:00 committed by GitHub
parent 8605cd2129
commit f88df82820
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23

View file

@ -10,7 +10,7 @@ from uuid import uuid4
import redis
from redis.exceptions import BusyLoadingError, ConnectionError
from rq import Queue, Worker
from rq import Callback, Queue, Worker
from rq.exceptions import NoSuchJobError
from rq.job import Job, JobStatus
from rq.logutils import setup_loghandlers
@ -145,8 +145,8 @@ def enqueue(
def enqueue_call():
return q.enqueue_call(
execute_job,
on_success=on_success,
on_failure=on_failure,
on_success=Callback(func=on_success) if on_success else None,
on_failure=Callback(func=on_failure) if on_failure else None,
timeout=timeout,
kwargs=queue_args,
at_front=at_front,