]h|6SrSSKJr SSKrSSKrSSKrSSKrSSKrSSKrSSK J r J r J r J r Jr \R"S5r"SS\5r"SS \5r"S S \5r"S S 5r"SS5r"SS5r\"5r\R2rS%S\S\4SjjrS&SjrS'S\SS4SjjrS(S\ \S\ \4SjjrS(S\ \SS4SjjrS\SS4Sjr S(S\ \S\ \R4Sjjr!S\ \"4Sjr#Sr$S \RS!\%4S"jr&S#\%S\4S$jr'g))a Python job scheduling for humans. github.com/dbader/schedule An in-process scheduler for periodic jobs that uses the builder pattern for configuration. Schedule lets you run Python functions (or any other callable) periodically at pre-determined intervals using a simple, human-friendly syntax. Inspired by Addam Wiggins' article "Rethinking Cron" [1] and the "clockwork" Ruby module [2][3]. Features: - A simple to use API for scheduling jobs. - Very lightweight and no external dependencies. - Excellent test coverage. - Tested on Python 3.7, 3.8, 3.9, 3.10, 3.11 and 3.12 Usage: >>> import schedule >>> import time >>> def job(message='stuff'): >>> print("I'm working on:", message) >>> schedule.every(10).minutes.do(job) >>> schedule.every(5).to(10).days.do(job) >>> schedule.every().hour.do(job, message='things') >>> schedule.every().day.at("10:30").do(job) >>> while True: >>> schedule.run_pending() >>> time.sleep(1) [1] https://adam.herokuapp.com/past/2010/4/13/rethinking_cron/ [2] https://github.com/Rykian/clockwork [3] https://adam.herokuapp.com/past/2010/6/30/replace_cron_with_clockwork/ )HashableN)SetListOptionalCallableUnionschedulec\rSrSrSrSrg) ScheduleError5zBase schedule exceptionN__name__ __module__ __qualname____firstlineno____doc____static_attributes__r C/var/www/html/env/lib/python3.13/site-packages/schedule/__init__.pyr r 5s!rr c\rSrSrSrSrg)ScheduleValueError;zBase schedule value errorr Nrr rrrr;s#rrc\rSrSrSrSrg) IntervalErrorAzAn improper interval was usedr Nrr rrrrAs'rrc\rSrSrSrSrg) CancelJobGz2 Can be returned from a job to unschedule itself. r Nrr rrrrGs  rrc\rSrSrSrSSjrSSjrSS\SS4SjjrSS \ \ S\ S 4S jjr SS \ \ SS4S jjr SS jrSS\SS 4SjjrSSjrSS \ \ S\ \R"4Sjjr\"\5r\S\ \4Sj5rSrg) SchedulerOz Objects instantiated by the :class:`Scheduler ` are factories to create jobs, keep record of scheduled jobs and handle their execution. returnNc/UlgNjobsselfs r__init__Scheduler.__init__Vs ! rcpSUR5n[U5HnURU5 M g)a< Run all jobs that are scheduled to run. Please note that it is *intended behavior that run_pending() does not run missed jobs*. For example, if you've registered a job that should run every minute and you only call run_pending() in one hour increments then your job won't be run 60 times in between but only once. c3J# UHoR(dMUv M g7fr%) should_run).0jobs r (Scheduler.run_pending..csD ^^ s# #N)r'sorted_run_job)r) runnable_jobsr0s r run_pendingScheduler.run_pendingYs.E D -(C MM# )r delay_secondsc[RS[UR5U5 URSSH*nUR U5 [ R "U5 M, g)a Run all jobs regardless if they are scheduled to run or not. A delay of `delay` seconds is added between each job. This helps distribute system load generated by the jobs more evenly over time. :param delay_seconds: A delay added between every executed job z/Running *all* %i jobs with %is delay in betweenN)loggerdebuglenr'r4timesleep)r)r8r0s rrun_allScheduler.run_allgsM  =  N  99Q# UHnTUR;dMUv M g7fr%)rD)r/r0rAs rr1"Scheduler.clear..sL9C3888KCC9s$ $)r:r;r')r)rAs `rclearScheduler.clearsG ; LL. / ! LL8# >L499LDIIaLrc[RS[U55 URR U5 g![ a" [RS[U55 gf=f)z@ Delete a scheduled job. :param job: The job to be unscheduled zCancelling job "%s"z!Cancelling not-scheduled job "%s"N)r:r;strr'remove ValueError)r)r0s r cancel_jobScheduler.cancel_jobsQ  H LL.C 9 II  S ! H LL` )rB)r)rRr0s reveryScheduler.everys(! rcUR5n[U[5(d U[LaURU5 ggr%)run isinstancerrP)r)r0rets rr4Scheduler._run_jobs2ggi c9 % % )9 OOC *:rcUR(dgURU5nU(dg[U5R$)z Datetime when the next job should run. :param tag: Filter the next run for the given tag parameter :return: A :class:`~datetime.datetime` object or None if no jobs scheduled N)r'rEminnext_run)r)rA jobs_filtereds r get_next_runScheduler.get_next_runs3yy c* =!***rcUR(dgUR[RR5- R5$)z{ :return: Number of seconds until :meth:`next_run ` or None if no jobs are scheduled N)r]datetimenow total_secondsr(s r idle_secondsScheduler.idle_secondss5}}  1 1 5 5 77FFHHrr&r#Nrr%)r0rBr#N)rrrrrr*r6intr?rrrrErJrPrTr4rbr_propertyr]floatrerr rrr!r!Os " &S&&& AHX. A$u+ A M(+ Mt M Hc%! )-+H%+ (## $+$ %H IhuoIIrr!c\rSrSrSrS4S\S\\4SjjrS\ 4Sjr S\ 4S jr S r \S 5r\S 5r\S 5r\S5r\S5r\S5r\S5r\S5r\S5r\S5r\S5r\S5r\S5r\S5r\S5r\S5r\S5rS\ 4Sjr!S4S\ S\\ 4S jjr"S!\4S"jr#S#\$\%RJ\%RL\%RN\ 44S$jr(S%\)4S&jr*\S\ 4S'j5r+S(r,S5S)jr-S*\%RJS\%RJ4S+jr.S*\%RJS,\ S\%RJ4S-jr/S.\%RJ4S/jr0S0\ S1\1\ S\\%RJ4S2jr2S3r3g)6rBa+ A periodic job as used by :class:`Scheduler`. :param interval: A quantity of a certain time unit :param scheduler: The :class:`Scheduler ` instance that this job will register itself with once it has been fully configured in :meth:`Job.do()`. Every job runs at a given fixed time interval that is defined by: * a :meth:`time unit ` * a quantity of `time units` defined by `interval` A job is usually created and returned by :meth:`Scheduler.every` method, which also defines its `interval`. NrR schedulercXlSUlSUlSUlSUlSUlSUlSUlSUlSUl [5Ul X l gr%) rRlatestjob_funcunitat_time at_time_zonelast_runr] start_day cancel_aftersetrDrp)r)rRrps rr* Job.__init__sd% %) 59 $( 15 !6: 6: )-:>#&5 .7rr#c4URUR:$)zF PeriodicJobs are sortable based on the scheduled time they run next. )r])r)others r__lt__ Job.__lt__s }}u~~--rcv[URS5(aURRnO[UR5nSR UR UR UURcSOURRURcS5$URR5$)Nrz4Job(interval={}, unit={}, do={}, args={}, kwargs={})z()z{}) hasattrrsrreprformatrRrtargskeywords)r) job_func_names r__str__ Job.__str__s 4==* - - MM22M /MFNN MM II MM)Dt}}/A/AMM)D   04}}/E/E   rc SnSnSU"UR5<SU"UR5<S3n[URS5(aURRnO[ UR5nURbURR Vs/sH%oR"U5(a [ U5O [U5PM' nnURRR5VVs/sHupxU<S[ U5<3PM n nnUS-S RXi-5-S-n OS n URbSS UR<S URS :XaURSSO UR<SUR<SU <S U<3 $SURbSOS-S-n U [URURURS :XaURSSO URU US9-$s snfs snnf)Nc6U(aURS5$S$)N%Y-%m-%d %H:%M:%Sz[never])strftime)ts r format_time!Job.__repr__..format_times671::12 FY Frc,[U[5(+$r%)rXrB)js ris_reprJob.__repr__..is_reprs!!S)) )rz (last run: z , next run: )r=(z, z[None]zEvery  rjz at z do zEvery %(interval)s zto %(latest)s z'%(unit)s do %(call_repr)s %(timestats)s)rRrrrt call_repr timestats)rwr]rrsrrrrMritemsjoinrurRrtrrdict) r)rrrrxrkvkwargsrfmts r__repr__ Job.__repr__s G *  &  & 4==* - - MM22M /M == $?C}}?Q?QR?Q!wqzzDGs1v5?QDR9=9O9O9U9U9WX9WDG,9WFX%+dii .FFLI I << # "&--1"4 #2$))C   &'+{{'>#BH;<  {{(, (:diin ##  +SXs ,G73G<cPURS:wa [S5eUR$)NrjzUse seconds instead of second)rRrsecondsr(s rsecond Job.secondE$ ==A  ?@ @||rcSUlU$)Nrrtr(s rr Job.secondsK  rcPURS:wa [S5eUR$)NrjzUse minutes instead of minute)rRrminutesr(s rminute Job.minutePrrcSUlU$)Nrrr(s rr Job.minutesVrrcPURS:wa [S5eUR$)NrjzUse hours instead of hour)rRrhoursr(s rhourJob.hour[$ ==A  ;< <zzrcSUlU$)Nrrr(s rr Job.hoursa  rcPURS:wa [S5eUR$)NrjzUse days instead of day)rRrdaysr(s rdayJob.dayfs$ ==A  9: :yyrcSUlU$)Nrrr(s rrJob.daysls  rcPURS:wa [S5eUR$)NrjzUse weeks instead of week)rRrweeksr(s rweekJob.weekqrrcSUlU$)Nrrr(s rr Job.weekswrrc^URS:wa [S5eSUlUR$)NrjzScheduling .monday() jobs is only allowed for weekly jobs. Using .monday() on a job scheduled to run every 2 or more weeks is not supported.mondayrRrrxrr(s rr Job.monday|3 ==A $  "zzrc^URS:wa [S5eSUlUR$)NrjzScheduling .tuesday() jobs is only allowed for weekly jobs. Using .tuesday() on a job scheduled to run every 2 or more weeks is not supported.tuesdayrr(s rr Job.tuesdays3 ==A $  #zzrc^URS:wa [S5eSUlUR$)NrjzScheduling .wednesday() jobs is only allowed for weekly jobs. Using .wednesday() on a job scheduled to run every 2 or more weeks is not supported. wednesdayrr(s rr Job.wednesdays3 ==A $  %zzrc^URS:wa [S5eSUlUR$)NrjzScheduling .thursday() jobs is only allowed for weekly jobs. Using .thursday() on a job scheduled to run every 2 or more weeks is not supported.thursdayrr(s rr Job.thursday3 ==A $  $zzrc^URS:wa [S5eSUlUR$)NrjzScheduling .friday() jobs is only allowed for weekly jobs. Using .friday() on a job scheduled to run every 2 or more weeks is not supported.fridayrr(s rr Job.fridayrrc^URS:wa [S5eSUlUR$)NrjzScheduling .saturday() jobs is only allowed for weekly jobs. Using .saturday() on a job scheduled to run every 2 or more weeks is not supported.saturdayrr(s rr Job.saturdayrrc^URS:wa [S5eSUlUR$)NrjzScheduling .sunday() jobs is only allowed for weekly jobs. Using .sunday() on a job scheduled to run every 2 or more weeks is not supported.sundayrr(s rr Job.sundayrrrDc[SU55(d [S5eURRU5 U$)z Tags the job with one or more unique identifiers. Tags must be hashable. Duplicate tags are discarded. :param tags: A unique list of ``Hashable`` tags. :return: The invoked job instance c3B# UHn[U[5v M g7fr%)rXr)r/rAs rr1Job.tag..s=:c8,,szTags must be hashable)all TypeErrorrDupdate)r)rDs rrAJob.tags8====34 4  rtime_strtzc8URS;aUR(d [S5eUb\SSKn[ U[ 5(aUR U5UlO,[ X#R5(aX lO [S5e[ U[ 5(d [S5eURS:XdUR(a'[R"SU5(d [S 5eURS :Xa'[R"S U5(d [S 5eURS :Xa'[R"SU5(d [S5eURS5n[U5S:XaUupVnOg[U5S:XaURS :Xa SnSnUupO?[U5S:Xa*URS :Xa[US5(aSnUupgOUupVSnURS:XdUR(a&[U5nSUs=::aS::d O [S5eO'URS :XaSnOURS :XaSnSn[U5n[U5n[U5n[R "XVU5UlU$)a Specify a particular time that the job should be run at. :param time_str: A string in one of the following formats: - For daily jobs -> `HH:MM:SS` or `HH:MM` - For hourly jobs -> `MM:SS` or `:MM` - For minute jobs -> `:SS` The format must make sense given how often the job is repeating; for example, a job that repeats every minute should not be given a string in the form `HH:MM:SS`. The difference between `:MM` and `:SS` is inferred from the selected time-unit (e.g. `every().hour.at(':30')` vs. `every().minute.at(':30')`). :param tz: The timezone that this timestamp refers to. Can be a string that can be parsed by pytz.timezone(), or a pytz.BaseTzInfo object :return: The invoked job instance )rrrz=Invalid unit (valid units are `days`, `hours`, and `minutes`)Nrz/Timezone must be string or pytz.timezone objectzat() should be passed a stringrz^[0-2]\d:[0-5]\d(:[0-5]\d)?$zAInvalid time format for a daily job (valid format is HH:MM(:SS)?)rz^([0-5]\d)?:[0-5]\d$z@Invalid time format for an hourly job (valid format is (MM)?:SS)rz ^:[0-5]\d$z "c""$(MM"$5!B00$&!(E(C((<= = 99 $..88;XFF(W 99 883X>>(V 99 !88M844(RnnS)  { q #. D&   "tyyI'=DF#IAv   "tyyG';KPQN@S@SD(NFF&LDF 99 $..t9DOO(J$YY' !D YY) #DF4yVV}}T6:  rrrcXlU$)a Schedule the job to run at an irregular (randomized) interval. The job's interval will randomly vary from the value given to `every` to `latest`. The range defined is inclusive on both ends. For example, `every(A).to(B).seconds` executes the job function every N seconds such that A <= N <= B. :param latest: Maximum interval between randomized job runs :return: The invoked job instance )rr)r)rrs rtoJob.to1s  r until_timecH[U[R5(aXlGOC[U[R5(a'[RR 5U-UlO[U[R 5(aB[RR [RR 5U5UlO[U[5(a|URU/SQ5nUc [S5eSU;aM[RR 5nURURURURS9nX lO [S5eUR[RR 5:a [S5eU$)a Schedule job to run until the specified moment. The job is canceled whenever the next run is calculated and it turns out the next run is after the until_time. The job is also canceled right before it runs, if the current time is after until_time. This latter case can happen when the the job was scheduled to run before until_time, but runs after until_time. If until_time is a moment in the past, ScheduleValueError is thrown. :param until_time: A moment in the future representing the latest time a job can be run. If only a time is supplied, the date is set to today. The following formats are accepted: - datetime.datetime - datetime.timedelta - datetime.time - String in one of the following formats: "%Y-%m-%d %H:%M:%S", "%Y-%m-%d %H:%M", "%Y-%m-%d", "%H:%M:%S", "%H:%M" as defined by strptime() behaviour. If an invalid string format is passed, ScheduleValueError is thrown. :return: The invoked job instance )rz%Y-%m-%d %H:%Mz%Y-%m-%dz%H:%M:%Sz%H:%Mz!Invalid string format for until()-)yearmonthrzVuntil() takes a string, datetime.datetime, datetime.timedelta, datetime.time parameterz5Cannot schedule a job to run until a time in the past)rXrbry timedeltarcr=combinerM_decode_datetimestrrreplacerrrr)r)rryrcs runtil Job.until@sY: j("3"3 4 4 *   H$6$6 7 7 ( 1 1 5 5 7* DD   HMM 2 2 ( 1 1 9 9!!%%'!D  C ( (33 L#()LMM*$''++-+33 4  !- *    x00446 6$G  rrsc [R"U/UQ70UD6Ul[R"URU5 UR 5 UR c [ S5eUR RRU5 U$)z Specifies the job_func that should be called every time the job runs. Any additional arguments are passed on to job_func when the job runs. :param job_func: The function to be scheduled :return: The invoked job instance zHUnable to a add job to schedule. Job is not associated with an scheduler) functoolspartialrsupdate_wrapper_schedule_next_runrpr r'append)r)rsrrs rdoJob.dos{"))(DTDVD   9 ! >> !:  ""4( rcURcS5e[RR5UR:$)z1 :return: ``True`` if the job should be run now. z"must run _schedule_next_run before)r]rbrcr(s rr.Job.should_runs8 }}(N*NN(  $$&$--77rcUR[RR55(a[R SU5 [ $[R SU5 UR 5n[RR5UlUR5 URUR5(a[R SU5 [ $U$)a Run the job and immediately reschedule it. If the job's deadline is reached (configured using .until()), the job is not run and CancelJob is returned immediately. If the next scheduled run exceeds the job's deadline, CancelJob is returned after the execution. In this latter case CancelJob takes priority over any other returned value. :return: The return value returned by the `job_func`, or CancelJob if the job's deadline is reached. zCancelling job %szRunning job %s) _is_overduerbrcr:r;rrsrwr r])r)rYs rrWJob.runs   H--113 4 4 LL,d 3  %t,mmo ))--/  !   DMM * * LL,d 3  rc,URS;a [S5eURbQURUR:d [ S5e[ R "URUR5nO URn[RRUR5nUnURb0URS:wa [S5e[X0R5nURbURU5n[R"S 0URU0D6nUS:waX4- nX2::a X4- nX2::aM URX0RSLS9nURbUR!5nUR#SS 9nX0lg) z4 Compute the instant when this job should run next. )rrrrrzQInvalid unit (valid units are `seconds`, `minutes`, `hours`, `days`, and `weeks`)Nz#`latest` is greater than `interval`rz`unit` should be 'weeks'rj fixate_time)tzinfor )rtrrrrRr randomrandintrbrcrvrx_move_to_next_weekdayru_move_to_at_timer_correct_utc_offset astimezonerr])r)rRrcr]periods rr Job._schedule_next_runso 99L L$'  ;; "KK4==0#$IJJ~~dmmT[[AH}}H##D$5$56 >> %yyG#()CDD,X~~FH << #,,X6H##` on the :data:`default scheduler instance `. )default_schedulerrT)rRs rrTrTKs  " "8 ,,rc,[R5 g)zqCalls :meth:`run_pending ` on the :data:`default scheduler instance `. N)r7r6r rrr6r6Rs!!#rr8c*[RUS9 g)ziCalls :meth:`run_all ` on the :data:`default scheduler instance `. r8N)r7r?r:s rr?r?YsM:rrAc,[RU5$)zkCalls :meth:`get_jobs ` on the :data:`default scheduler instance `. )r7rErAs rrErE`s  % %c **rc.[RU5 g)zeCalls :meth:`clear ` on the :data:`default scheduler instance `. N)r7rJr<s rrJrJgsC rr0c.[RU5 g)zoCalls :meth:`cancel_job ` on the :data:`default scheduler instance `. N)r7rP)r0s rrPrPns  %rc,[RU5$)zkCalls :meth:`next_run ` on the :data:`default scheduler instance `. )r7r_r<s rr]r]us  ) )# ..rc"[R$)zsCalls :meth:`idle_seconds ` on the :data:`default scheduler instance `. )r7rer rrrere|s  ) ))rc^^^UUU4SjnU$)z Decorator to schedule a new periodic job. Any additional arguments are passed on to the decorated function when the job runs. :param job: a :class:`Jobs ` c4>TR"U/TQ70TD6 U$r%)r )decorated_functionrr0rs r_schedule_decorator#repeat.._schedule_decorators  !3D3F3!!rr )r0rrrDs``` rrepeatrFs" rr weekdayc[U5nX R5- nUS:aUS- nU[R"US9-$)z Move the given timestamp to the nearest given weekday. May be this week or next week. If the timestamp is already at the given weekday, it is not moved. r)r)_weekday_indexrGrbr)r rG weekday_index days_aheads rrrsC #7+M!11JA~a H&&J7 77rrcfSnX;a[SRU55eURU5$)N)rrrrrrrz+Invalid start day (valid start days are {}))rrindex)rweekdayss rrJrJs=H  9 @ @ J   >># rrirgrhr%)(rcollections.abcrrbrloggingrrr=typingrrrrr getLoggerr: Exceptionr rrrr!rBr7r'rkrTr6r?rErJrPr]rmrerFrMrrJr rrrUsp&P% 77   : & I    &   IIDm m hK-C--$;3;t;+(8$+S +!x!!T!&C&D&/(8$/9J9J0K/*huo*" 8("3"3 8c 8r