Ë ÌAHjÐãóŠ—ddlmZddlmZddlmZddlmZmZddlm Z e rddl m Z ddl m Z dd lmZeGd „d ««Zy ) é)Ú annotations)ÚIterable)Ú dataclass)ÚdatetimeÚ timedelta)Ú TYPE_CHECKING)ÚPipelineé)ÚJob)ÚQueuecóV—eZdZUdZded<ded<d d d„Zed d„«Zed dd „«Zy)Ú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. ÚintÚtimesú list[int]Ú intervalscó—|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Ú isinstancerrrÚlistÚ TypeErrorr)ÚselfrÚintervalÚ interval_listÚis úA/root/tools/cai/cai_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ócó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)ÚclsÚcountrs rÚ get_intervalzRepeat.get_interval:s%€ð ”C˜ “NÒ "ؘR‘=Ð à˜ÑÐrNcó(—|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 )Úpipeline)Úseconds)Ú repeats_leftrÚidÚ connectionr&Úrepeat_intervalsr$ÚsaveÚ _enqueue_jobrÚnowrÚ schedule_jobÚexecute)r"ÚjobÚqueuer&ÚpipeÚ repeat_countrÚscheduled_times rÚschedulezRepeat.scheduleKs€ð" × Ñ Ð # 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)rrrzint | Iterable[int] | None)r#rrrÚreturnr)N)r1r r2r r&zPipeline | None) Ú__name__Ú __module__Ú __qualname__Ú__doc__Ú__annotations__rÚ classmethodr$r6©rrrrsA…ñð ƒJØÓôð:ò óð ð ó*óñ*rrN)Ú __future__rÚcollections.abcrÚ dataclassesrrrÚtypingrÚ redis.clientr r1r r2r rr>rrúrDs<ðÝ"å$Ý!ß(Ý áÝ%åÝð ÷fðfó ñfr