File tree Expand file tree Collapse file tree 1 file changed +9
-6
lines changed
Expand file tree Collapse file tree 1 file changed +9
-6
lines changed Original file line number Diff line number Diff line change 2323except ImportError :
2424 raise DidNotEnable ("RQ not installed" )
2525
26+ try :
27+ from rq .worker import BaseWorker
28+
29+ if not hasattr (BaseWorker , "perform_job" ):
30+ BaseWorker = None
31+ except ImportError :
32+ BaseWorker = None
33+
2634from typing import TYPE_CHECKING
2735
2836if TYPE_CHECKING :
@@ -47,12 +55,7 @@ def setup_once() -> None:
4755 # instead of Worker, so we need to patch BaseWorker to cover both.
4856 # For older versions where BaseWorker doesn't exist or doesn't have
4957 # perform_job, we patch Worker.
50- try :
51- from rq .worker import BaseWorker
52-
53- worker_cls = BaseWorker if hasattr (BaseWorker , "perform_job" ) else Worker
54- except ImportError :
55- worker_cls = Worker
58+ worker_cls = BaseWorker if BaseWorker is not None else Worker
5659
5760 old_perform_job = worker_cls .perform_job
5861
You can’t perform that action at this time.
0 commit comments