s,gddlmZddlmZmZmZmZmZmZm Z m Z er ddl m Z ddl mZddlmZddl mZddlmZdd lmZGd d Z y ) )wraps) TYPE_CHECKINGAnyCallableDictListOptionalTypeUnion)Redis)Retry)DEFAULT_RESULT_TTL)Callback)Queue) backend_classc$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||_t|d||_||_||_||_||_| |_||_||_ | |_ | |_ | |_ ||_ | |_||_y)akA 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): Arbitraty metadata about the job. Defaults to None. description (Optional[str], optional): Job description. Defaults to None. failure_ttl (Optional[int], optional): Failture 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. r)overrideN)rrrrrrrrrrrrr r"r!r#)selfrrrrrrrrrrrr r!r"r#s g/var/www/trellinator.diamondhoofcare.com/public_html/venv/lib/python3.12/site-packages/rq/decorators.py__init__z job.__init__szh (}{S$ $ $  && $$$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-rrrrr r!r"r#) isinstancerstrrrpoprr enqueue_callrrrrrrr r!r"r#)r.r/rrr-rfr&s r'delayzjob.__call__..delayWs$**c*((djjT__(U L$7JZZ$/Fzz*e4H!__ ==%% ??HH%!YY ,, ,,jj??????!& r))rr5enqueue)r&r4r5s`` r'__call__z job.__call__Vs/ q!  ! F r))__name__ __module__ __qualname__rrrr r1r intr rrboolrrrr(r7r)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) functoolsrtypingrrrrrr r r redisr rrdefaultsrrrrutilsrr=r)r'rCs2RRR( nnr)