]jddlmZddlmZmZmZmZmZer ddlm Z ddl m Z ddl m Z ddl mZddlmZGd d Z y ) )wraps) TYPE_CHECKINGAnyCallableOptionalUnion)Redis)Retry)DEFAULT_RESULT_TTL)Callback)Queuec$eZdZeZdedddddddddddf dedefdddee de d ee d ee dd ee e d e d eee e fdeedee deddeeeede ffdeeeede ffdeeeede fffdZdZy)jobNFqueuer connectionr timeout result_ttlttl queue_class depends_onat_frontmeta description failure_ttlretryr on_failure. on_success on_stoppedc||_|r|nt|_||_||_||_||_| |_||_||_ | |_ | |_ | |_ ||_ | |_||_y)ajA decorator that adds a ``enqueue`` method to the decorated function, which in turn creates a RQ job when called. Accepts a required ``queue`` argument that can be either a ``Queue`` instance or a string denoting the queue name. For example:: ..codeblock:python:: >>> @job(queue='default') >>> def simple_add(x, y): >>> return x + y >>> ... >>> # Puts `simple_add` function into queue >>> simple_add.enqueue(1, 2) Args: queue (Union['Queue', str]): The queue to use, can be the Queue class itself, or the queue name (str) connection (Optional[Redis], optional): Redis Connection. Defaults to None. timeout (Optional[int], optional): Job timeout. Defaults to None. result_ttl (int, optional): Result time to live. Defaults to DEFAULT_RESULT_TTL. ttl (Optional[int], optional): Time to live. Defaults to None. queue_class (Optional[Queue], optional): A custom class that inherits from `Queue`. Defaults to None. depends_on (Optional[List[Any]], optional): A list of dependents jobs. Defaults to None. at_front (Optional[bool], optional): Whether to enqueue the job at front of the queue. Defaults to None. meta (Optional[Dict[Any, Any]], optional): Arbitrary metadata about the job. Defaults to None. description (Optional[str], optional): Job description. Defaults to None. failure_ttl (Optional[int], optional): Failure time to live. Defaults to None. retry (Optional[Retry], optional): A Retry object. Defaults to None. on_failure (Optional[Union[Callback, Callable[..., Any]]], optional): Callable to run on failure. Defaults to None. on_success (Optional[Union[Callback, Callable[..., Any]]], optional): Callable to run on success. Defaults to None. on_stopped (Optional[Union[Callback, Callable[..., Any]]], optional): Callable to run when stopped. Defaults to None. N)rrrrrrrrrrrrrrrr)selfrrrrrrrrrrrrrrrs 7/root/env/lib/python3.12/site-packages/rq/decorators.py__init__z job.__init__suh *5;5$ $ $  && $$$cNtfd}|_|_S)NcNtjtr(jjj}n j}|j dd}|j dd}|j dd}|s j }|s j}|j||jjj|||jjjjj j"j$S)N)namerrjob_idrF)argskwargsrrrrr(rrrrrrrr) isinstancerstrrrpoprr enqueue_callrrrrrrrrrr)r)r*rrr(rfr!s r"delayzjob.__call__..delayVs$**c*((djjT__(U L$7JZZ$/Fzz*e4H!__ ==%% ??HH%!YY ,, ,,jj??????!& r$)rr0enqueue)r!r/r0s`` r"__call__z job.__call__Us/ q!  ! F r$)__name__ __module__ __qualname__rrr rr,rinttypelistrbooldictr rr#r2r$r"rrsdK "&,!/3*.)-%)%)#'DHDHDH!B%Wc\"B%B%# B%  B% c] B%d7m,B%T#Y'B%B%tCH~&B%c]B%c]B% B%U8Xc3h-?#?@AB%U8Xc3h-?#?@AB% U8Xc3h-?#?@A!B%H'r$rN) functoolsrtypingrrrrrredisr rr defaultsr r rrr;r$r"r@s,@@(nnr$