]jgTddlmZddlmZmZmZmZmZm Z m Z m Z ddl m Z mZe r4ddlmZddlmZddlmZedZe d d ZGd d eeefZeddZe dde defdeddedededgdff dZ dde ddefdeddedede dedgdfff dZy))job)AnyCallableOptionaloverloadProtocol TYPE_CHECKINGTypeVarUnion) get_queueget_result_ttl)Redis)Queue) ParamSpecPRT) covariantceZdZdejdej defdZdejdej defdZdejdej defdZ y)_JobFnargskwargsreturncyNselfrrs >/root/env/lib/python3.12/site-packages/django_rq/decorators.pydelayz _JobFn.delaycyrrrs renqueuez_JobFn.enqueuer!r"cyrrrs r__call__z_JobFn.__call__r!r"N) __name__ __module__ __qualname__rrrrr r$r&rr"rrrsPDqvvDDaDFF188FFG!&&GAHHGGr"r func_or_queueCallable[P, R]r _JobFn[P, R]cyrr)r*s rrrst|r|}d}nd}|}d}t|tr|} t|}| |j}n| |j}|j dt||d<||d<t|g|i|}|r||S|S#t $rYIwxYw)a/ The same as RQ's job decorator, but it automatically works out the ``connection`` argument from RQ_QUEUES. And also, it allows simplified ``@job`` syntax to put job into default queue. If ``result_ttl`` is not passed, It set the default ttl to the queue `DEFAULT_RESULT_TTL`. defaultN result_ttlr.) callable isinstancestrr r.KeyErrorgetr_rq_job)r*r.rrfuncqueue queue_name decorators rrr!s %.J%  e$E!"--   ))J!::lN:4NOF<%F<///I     sB BB)r*r+rr,r) rq.decoratorsrr8typingrrrrrr r r queuesr rredisrrqrtyping_extensionsrrrrr5rr"rrCs (]]]-+#At$AH!Q$H  ? ? %)7#&7!7 7 7  .01 7 7%)()7C78(!( ( (  >8%5$6$FG GH (r"