o /i@szddlmZddlmZddlmZmZddlmZmZm Z er2ddl m Z ddl m Z ddlmZeGd d d Zd S) )Iterable) dataclass)datetime timedelta) TYPE_CHECKINGOptionalUnion)Pipeline)Job)Queuec @seZdZUdZeed<eeed<ddedeeee effddZ e dedeed efd d Z e dd ddddedfddZ d S)RepeataDefines repeat behavior for scheduled jobs. Attributes: times (int): The number of times to repeat the job. Must be greater than 0. intervals (Union[int, List[int]]): The intervals between job executions in seconds. Can be a single integer value or a list of intervals. If a list is provided and it's shorter than (times-1), the last interval will be reused for remaining repeats. times intervalsrintervalcCsz|dkrtdt|tr|dkrtd|g|_nt|tr4t|}|D] }|dkr/tdq%||_ntd||_dS)aInitialize a Repeat instance. Args: times (int): The number of times to repeat the job. Must be greater than 0. interval (Optional[Union[int, Iterable[int]]], optional): The intervals between job executions in seconds. Can be a single integer value or a list of intervals. Defaults to 0 (immediately repeated). Raises: ValueError: If times is less than 1 or if intervals contains negative values. r z*times: please enter a value greater than 0rz+intervals: negative numbers are not allowedz,intervals must be an int or iterable of intsN) ValueError isinstanceintrrlist TypeErrorr)selfrr interval_listirI/var/www/html/flask_server/venv/lib/python3.10/site-packages/rq/repeat.py__init__s     zRepeat.__init__countreturncCs|t|kr |dS||S)zReturns the appropriate interval based on the repeat count. Args: count (int): Current repeat count (0-based) intervals (List[int]): List of intervals Returns: int: The interval to use )len)clsrrrrr get_interval8s zRepeat.get_intervalNjobr queuer pipeliner cCs|jdus |jdkrtd|jd|dur|n|j}|jd}d}|jr/|||j}|jd|_|j|d|dkrG|j||dnt t |d}|j |||d|durb| dSdS)aQSchedules a job to repeat based on its repeat configuration. This decrements the job's repeats_left counter and either enqueues it immediately (if interval is 0) or schedules it to run after the specified interval. Args: job (Job): The job to repeat queue (Queue): The queue to enqueue/schedule the job on pipeline (Optional[Pipeline], optional): Redis pipeline to use. Defaults to None. Returns: scheduled_time (Optional[datetime]): When the job was scheduled to run, or None if not scheduled NrzCannot schedule job z: no repeats leftr )r$)seconds) repeats_leftrid connectionr$repeat_intervalsr!save _enqueue_jobrnowr schedule_jobexecute)r r"r#r$pipe repeat_countrscheduled_timerrrscheduleIs     zRepeat.schedule)r)N)__name__ __module__ __qualname____doc__r__annotations__rrrrr classmethodr!r2rrrrr s  $"r N)collections.abcr dataclassesrrrtypingrrr redis.clientr r"r r#r r rrrrs