]jL ddlmZmZmZddlmZddlmZddlm Z ddl m Z ddl m Z ddlmZmZd Zdd Zd d d d d edeeeeefdeeeeefdeeeeefdef dZy ))OptionalTypeUnion)Worker)Job)import_attribute)settings) get_job_class)DjangoRQ get_queuescJddlm}|Dcgc] }t|c}Scc}w)z Custom exception handlers could be defined in settings.py: RQ = { 'EXCEPTION_HANDLERS': ['path.to.handler'], } r )EXCEPTION_HANDLERS)r rr)rpaths ;/root/env/lib/python3.12/site-packages/django_rq/workers.pyget_exception_handlersr s!-/A Bt T " BB Bs Ncttdi}|t}d|vr|jd}t |t r t |}|S)z Return worker class from RQ settings, otherwise return Worker. If `worker_class` is not None, it is used as an override (can be python import path as string). RQ WORKER_CLASS)getattrr rget isinstancestrr) worker_classrs rget_worker_classrsM 4 $B R 66.1L,$' 5 ) job_class queue_classr queue_namesrrrreturnct|}t|||d}|dj}t|}||f|djt xsd||d|S)z? Returns a RQ worker for all queues or specified ones. )rrrN) connectionexception_handlersrr)r r __class__rr"r)rrrrkwargsqueuess r get_workerr'+sri(I  { SF)%%K#L1L  !9''13;t     r)N)typingrrrrqrrq.jobrrq.utilsr django.confr jobsr r&r r rrrr'rrr/s((% ( C(268<7; c49n-.%T(^ 3455d6l!234   r