o i@szddlmZddlmZmZmZmZmZer"ddlm Z ddl m Z ddl m Z ddl mZddlmZGd d d Z d S) )wraps) TYPE_CHECKINGAnyCallableOptionalUnion)Redis)Retry)DEFAULT_RESULT_TTL)Callback)Queuec$@seZdZeZdedddddddddddf dedefdddee de d ee d ee dd ee e d e d eee e fdeedee deddeeeede ffdeeeede ffdeeeede fffddZddZdS)jobNFqueuer connectionrtimeout result_ttlttl queue_class depends_onat_frontmeta description failure_ttlretryr on_failure. on_success on_stoppedcCsf||_|r|nt|_||_||_||_||_| |_||_||_ | |_ | |_ | |_ ||_ | |_||_dS)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)rr rrrrrrrrrrrrrr)selfrrrrrrrrrrrrrrrrD/home/app/Keep/.python/lib/python3.10/site-packages/rq/decorators.py__init__s4 z job.__init__cs&tfdd}|_|_S)Ncstjtrjjjd}nj}|dd}|dd}|dd}|s*j}|s/j}|jf||j j j |||j j jjjjjdS)N)namerrjob_idrF)argskwargsrrrrr#rrrrrrrr) isinstancerstrrrpoprrZ enqueue_callrrrrrrrrrr)r$r%rrr#rfrrr delayVs:    zjob.__call__..delay)rr+enqueue)rr*r+rr)r __call__Us #z job.__call__)__name__ __module__ __qualname__r rr rr'rinttypelistrbooldictr rr!r-rrrr rs^         DrN) functoolsrtypingrrrrrZredisrrr defaultsr r rr rrrr s