Ë ]jÏãó†—ddlmZddlmZddlmZmZddlmZmZm Z erddl m Z ddl m Z ddlmZeGd „d ««Zy ) é)ÚIterable)Ú dataclass)ÚdatetimeÚ timedelta)Ú TYPE_CHECKINGÚOptionalÚUnion)ÚPipelineé)ÚJob)ÚQueuec óž—eZdZUdZeed<eeed<ddedeeee effd„Z e dedeedefd„«Z e dd d d d dedfd„«Z y )ÚRepeata®Defines 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Ú intervalsÚintervalcó—|dkr td«‚t|t«r |dkr td«‚|g|_||_yt|t«r1t |«}|D]}|dksŒ td«‚||_||_yt d«‚)aÛInitialize 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Ú isinstanceÚintrrÚlistÚ TypeErrorr)ÚselfrrÚ interval_listÚis ú3/root/env/lib/python3.12/site-packages/rq/repeat.pyÚ__init__zRepeat.__init__sŸ€ð 1Š9ÜÐIÓJÐ Jä h¤Ô $ؘ!Š|Ü Ð!NÓOÐOØ&˜ZˆDŒNðˆ ô˜¤(Ô +Ü  ›NˆMØ"ò TØq“5Ü$Ð%RÓSÐSð Tð+ˆDŒNðˆ ôÐJÓKÐ KóÚcountÚreturncó2—|t|«k\r|dS||S)z÷Returns 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)Úclsrrs rÚ get_intervalzRepeat.get_interval8s%€ð ”C˜ “NÒ "ؘR‘=Ð à˜ÑÐrNÚjobr Úqueuer Úpipeliner có(—|j|jdkrtd|j›d«‚||n|jj «}|jdz }d}|j r|j ||j «}|jdz |_|j|¬«|dk(r|j||¬«n5tj«t|¬«z}|j|||¬«|€|j«yy)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_leftrÚidÚ connectionr(Úrepeat_intervalsr%ÚsaveÚ _enqueue_jobrÚnowrÚ schedule_jobÚexecute)r$r&r'r(ÚpipeÚ repeat_countrÚscheduled_times rÚschedulezRepeat.scheduleIs€ð" × Ñ Ð # s×'7Ñ'7¸1Ò'<ÜÐ3°C·F±F°8Ð;LÐMÓNÐ Nà#Ð/‰x°S·^±^×5LÑ5LÓ5Nˆð×'Ñ'¨!Ñ+ˆ ؈à × Ò Ø×'Ñ'¨ °c×6JÑ6JÓKˆHð×+Ñ+¨aÑ/ˆÔØ ‰˜$ˆÔà qŠ=à × Ñ ˜s¨TÐ Õ 2ô&Ÿ\™\›^¬iÀÔ.IÑIˆNØ × Ñ ˜s N¸TÐ Ô Bð Ð Ø L‰LNð r)r)N)Ú__name__Ú __module__Ú __qualname__Ú__doc__rÚ__annotations__rrr rrÚ classmethodr%r7©rrrr s™…ñð ƒJØC‰yÓñ˜cð¨X°e¸CÀÈ#ÁÐrrúrCs<ðÝ$Ý!ß(ß1Ñ1áÝ%åÝð ÷fðfó ñfr