Ñò ë{½Jc@sLdZddddddddd d d d d ddddddddddddgZddkZddkZddkZddkZddkZddkZddkl Z e dddƒZ d d=d „ƒYZ d d>d!„ƒYZ d e fd"„ƒYZ de fd#„ƒYZdd?d$„ƒYZdee fd%„ƒYZd ee fd&„ƒYZyddkZde fd'„ƒYZdd@d(„ƒYZd eefd)„ƒYZdee fd*„ƒYZdeefd+„ƒYZdeefd,„ƒYZWnej onXeed-ƒoddkZde fd.„ƒYZddAd/„ƒYZdeefd0„ƒYZdee fd1„ƒYZdeefd2„ƒYZ deefd3„ƒYZ!nda#d4„Z$d5„Z%d6„Z&ddd7e i'dd8„Z(ddd7e i'dd9„Z)dde i'dd:„Z*dde i'dd;„Z+d<„Z,dS(Bs÷Module that provides a cron-like task scheduler. This task scheduler is designed to be used from inside your own program. You can schedule Python functions to be called at specific intervals or days. It uses the standard 'sched' module for the actual task scheduling, but provides much more: * repeated tasks (at intervals, or on specific days) * error handling (exceptions in tasks don't kill the scheduler) * optional to run scheduler in its own thread or separate process * optional to run a task in its own thread or separate process If the threading module is available, you can use the various Threaded variants of the scheduler and associated tasks. If threading is not available, you could still use the forked variants. If fork is also not available, all processing is done in a single process, sequentially. There are three Scheduler classes: Scheduler ThreadedScheduler ForkedScheduler You usually add new tasks to a scheduler using the add_interval_task or add_daytime_task methods, with the appropriate processmethod argument to select sequential, threaded or forked processing. NOTE: it is impossible to add new tasks to a ForkedScheduler, after the scheduler has been started! For more control you can use one of the following Task classes and use schedule_task or schedule_task_abs: IntervalTask ThreadedIntervalTask ForkedIntervalTask SingleTask ThreadedSingleTask ForkedSingleTask WeekdayTask ThreadedWeekdayTask ForkedWeekdayTask MonthdayTask ThreadedMonthdayTask ForkedMonthdayTask Kronos is the Greek God of Time. This module is based on Kronos by Irmen de Jong, but has been modified to better fit within TurboGears. Additionally, this module appeared to no longer be supported/in development. tDayTaskReschedulertForkedIntervalTasktForkedMonthdayTasktForkedSchedulertForkedSingleTasktForkedTaskMixintForkedWeekdayTaskt IntervalTaskt MonthdayTaskt Schedulert SingleTasktTasktThreadedIntervalTasktThreadedMonthdayTasktThreadedSchedulertThreadedSingleTasktThreadedTaskMixintThreadedWeekdayTaskt WeekdayTasktadd_interval_tasktadd_monthday_tasktadd_single_tasktadd_weekday_tasktcanceltmethodiÿÿÿÿN(tEnumt sequentialtforkedtthreadedcBsƒeZdZd„Zd„Zd„Zd„Zd„Zd„Zd„Z d„Z d „Z d „Z d „Z d „Zd „ZRS(sThe Scheduler itself.cCs(t|_titi|iƒ|_dS(N(tTruetrunningtschedt schedulerttimet_Scheduler__delayfunc(tself((sr/afs/athena.mit.edu/user/x/a/xavid/lib/python2.6/site-packages/TurboGears-1.1rc1-py2.6.egg/turbogears/scheduler.pyt__init__[s cCsü|djoti|ƒnÛ|iidd}tiƒ|}d}||}xJ|io?|tiƒjo,|iidd|joti|ƒqUW|i p|iidd|jodStiƒ}||joti||ƒndS(Ni ii(R!tsleepRtqueueR(R#tdelayttoptimetendtimetperiodtstoptimetnow((sr/afs/athena.mit.edu/user/x/a/xavid/lib/python2.6/site-packages/TurboGears-1.1rc1-py2.6.egg/turbogears/scheduler.pyt __delayfunc_s  &  cCsdS(N((R#((sr/afs/athena.mit.edu/user/x/a/xavid/lib/python2.6/site-packages/TurboGears-1.1rc1-py2.6.egg/turbogears/scheduler.pyt _acquire_locktscCsdS(N((R#((sr/afs/athena.mit.edu/user/x/a/xavid/lib/python2.6/site-packages/TurboGears-1.1rc1-py2.6.egg/turbogears/scheduler.pyt _release_lockwsc CsÒ|djp |djotdƒ‚n|tijo t}nA|tijo t}n'|tijo t}n tdƒ‚|p g}n|p h}n||||||ƒ} |i| |ƒ| S(sAdd a new Interval Task to the schedule. A very short initialdelay or one of zero cannot be honored, you will see a slight delay before the task is first executed. This is because the scheduler needs to pick it up in its loop. iisDelay or interval must be >0sInvalid processmethod( t ValueErrorRRRRR RRt schedule_task( R#tactionttasknamet initialdelaytintervalt processmethodtargstkwt TaskClassttask((sr/afs/athena.mit.edu/user/x/a/xavid/lib/python2.6/site-packages/TurboGears-1.1rc1-py2.6.egg/turbogears/scheduler.pyRzs       c CsÂ|djotdƒ‚n|tijo t}nA|tijo t}n'|tijo t}n tdƒ‚|p g}n|p h}n|||||ƒ}|i||ƒ|S(s@Add a new task to the scheduler that will only be executed once.isDelay must be >0sInvalid processmethod( R0RRR RRRRR1( R#R2R3R4R6R7R8R9R:((sr/afs/athena.mit.edu/user/x/a/xavid/lib/python2.6/site-packages/TurboGears-1.1rc1-py2.6.egg/turbogears/scheduler.pyR–s        c Csc|o|otdƒ‚n|p g}n|p h}n|oy|tijo t} nA|tijo t} n'|tijo t} n tdƒ‚| ||||||ƒ} n|oy|tijo t} nA|tijo t } n'|tijo t } n tdƒ‚| ||||||ƒ} n| i t ƒ} |i | | ƒ| S(s9Add a new Day Task (Weekday or Monthday) to the schedule.s4You can only specify weekdays or monthdays, not bothsInvalid processmethod(R0RRRRRRRRR Rtget_schedule_timeRtschedule_task_abs( R#R2R3tweekdayst monthdayst timeondayR6R7R8R9R:t firsttime((sr/afs/athena.mit.edu/user/x/a/xavid/lib/python2.6/site-packages/TurboGears-1.1rc1-py2.6.egg/turbogears/scheduler.pytadd_daytime_task¬s6          c Cs‚|ioJ|iƒz.|ii|d|ti|ƒfƒ|_Wd|iƒXn+|ii|d|ti|ƒfƒ|_dS(s…Add a new task to the scheduler with the given delay (seconds). Low-level method for internal use. iN(RR.RtentertweakreftrefteventR/(R#R:R'((sr/afs/athena.mit.edu/user/x/a/xavid/lib/python2.6/site-packages/TurboGears-1.1rc1-py2.6.egg/turbogears/scheduler.pyR1Òs  c Cs‚|ioJ|iƒz.|ii|d|ti|ƒfƒ|_Wd|iƒXn+|ii|d|ti|ƒfƒ|_dS(sˆAdd a new task to the scheduler for the given absolute time value. Low-level method for internal use. iN(RR.RtenterabsRCRDRER/(R#R:tabstime((sr/afs/athena.mit.edu/user/x/a/xavid/lib/python2.6/site-packages/TurboGears-1.1rc1-py2.6.egg/turbogears/scheduler.pyR<äs  cCs|iƒdS(sStart the scheduler.N(t_run(R#((sr/afs/athena.mit.edu/user/x/a/xavid/lib/python2.6/site-packages/TurboGears-1.1rc1-py2.6.egg/turbogears/scheduler.pytstartöscCst|_g|ii(dS(s0Remove all pending tasks and stop the Scheduler.N(tFalseRRR&(R#((sr/afs/athena.mit.edu/user/x/a/xavid/lib/python2.6/site-packages/TurboGears-1.1rc1-py2.6.egg/turbogears/scheduler.pytstopús cCs|ii|iƒdS(sCancel given scheduled task.N(RRRE(R#R:((sr/afs/athena.mit.edu/user/x/a/xavid/lib/python2.6/site-packages/TurboGears-1.1rc1-py2.6.egg/turbogears/scheduler.pyRÿscCsŸx˜|ioy|iiƒWnZtj oN}tidI|IJtidititi ƒŒƒIJtidIJnX|iot i dƒqqWdS(Ns ERROR DURING SCHEDULER EXECUTIONtt-iis--------------------( RRtrunt Exceptiontsyststderrtjoint tracebacktformat_exceptiontexc_infoR!R%(R#tx((sr/afs/athena.mit.edu/user/x/a/xavid/lib/python2.6/site-packages/TurboGears-1.1rc1-py2.6.egg/turbogears/scheduler.pyRHs   (t__name__t __module__t__doc__R$R"R.R/RRRAR1R<RIRKRRH(((sr/afs/athena.mit.edu/user/x/a/xavid/lib/python2.6/site-packages/TurboGears-1.1rc1-py2.6.egg/turbogears/scheduler.pyR Xs       &     cBs;eZdZd„Zd„Zd„Zd„Zd„ZRS(s*Abstract base class of all scheduler taskscCs(||_||_||_||_dS(sThis is an abstract class!N(tnameR2R7R8(R#RZR2R7R8((sr/afs/athena.mit.edu/user/x/a/xavid/lib/python2.6/site-packages/TurboGears-1.1rc1-py2.6.egg/turbogears/scheduler.pyR$s   cCsGy|iƒWn"tj o}|i|ƒnX|i|ƒƒdS(s2Execute the task action in the scheduler's thread.N(texecuteROthandle_exceptiont reschedule(R#t schedulerrefRV((sr/afs/athena.mit.edu/user/x/a/xavid/lib/python2.6/site-packages/TurboGears-1.1rc1-py2.6.egg/turbogears/scheduler.pyt__call__s cCstdƒ‚dS(s8This method should be defined in one of the sub classes!sIYou're using the abstract base class 'Task', use a concrete class insteadN(tNotImplementedError(R#R ((sr/afs/athena.mit.edu/user/x/a/xavid/lib/python2.6/site-packages/TurboGears-1.1rc1-py2.6.egg/turbogears/scheduler.pyR]$scCs|i|i|iŽdS(sExecute the actual task.N(R2R7R8(R#((sr/afs/athena.mit.edu/user/x/a/xavid/lib/python2.6/site-packages/TurboGears-1.1rc1-py2.6.egg/turbogears/scheduler.pyR[)scCsItidI|IJtidititiƒŒƒIJtidIJdS(s8Handle any exception that occured during task execution.sERROR DURING TASK EXECUTIONRLRMiNs--------------------(RPRQRRRSRTRU(R#texc((sr/afs/athena.mit.edu/user/x/a/xavid/lib/python2.6/site-packages/TurboGears-1.1rc1-py2.6.egg/turbogears/scheduler.pyR\-s%(RWRXRYR$R_R]R[R\(((sr/afs/athena.mit.edu/user/x/a/xavid/lib/python2.6/site-packages/TurboGears-1.1rc1-py2.6.egg/turbogears/scheduler.pyR s     cBseZdZd„ZRS(sA task that only runs once.cCsdS(N((R#R ((sr/afs/athena.mit.edu/user/x/a/xavid/lib/python2.6/site-packages/TurboGears-1.1rc1-py2.6.egg/turbogears/scheduler.pyR]7s(RWRXRYR](((sr/afs/athena.mit.edu/user/x/a/xavid/lib/python2.6/site-packages/TurboGears-1.1rc1-py2.6.egg/turbogears/scheduler.pyR 4scBs&eZdZddd„Zd„ZRS(s>A repeated task that occurs at certain intervals (in seconds).cCs&ti|||||ƒ||_dS(N(R R$R5(R#RZR5R2R7R8((sr/afs/athena.mit.edu/user/x/a/xavid/lib/python2.6/site-packages/TurboGears-1.1rc1-py2.6.egg/turbogears/scheduler.pyR$>scCs|i||iƒdS(s<Reschedule this task according to its interval (in seconds).N(R1R5(R#R ((sr/afs/athena.mit.edu/user/x/a/xavid/lib/python2.6/site-packages/TurboGears-1.1rc1-py2.6.egg/turbogears/scheduler.pyR]BsN(RWRXRYtNoneR$R](((sr/afs/athena.mit.edu/user/x/a/xavid/lib/python2.6/site-packages/TurboGears-1.1rc1-py2.6.egg/turbogears/scheduler.pyR;scBs)eZdZd„Zd„Zd„ZRS(sBA mixin class that contains the reschedule logic for the DayTasks.cCs ||_dS(N(R?(R#R?((sr/afs/athena.mit.edu/user/x/a/xavid/lib/python2.6/site-packages/TurboGears-1.1rc1-py2.6.egg/turbogears/scheduler.pyR$JscCsttiƒƒ}|o6|d|df|ijo|dcd7R?R2R7R8((sr/afs/athena.mit.edu/user/x/a/xavid/lib/python2.6/site-packages/TurboGears-1.1rc1-py2.6.egg/turbogears/scheduler.pyR$ˆs,cCs7tiƒi|ijo|i|i|iŽndS(N(R!Rdttm_mdayRkR2R7R8(R#((sr/afs/athena.mit.edu/user/x/a/xavid/lib/python2.6/site-packages/TurboGears-1.1rc1-py2.6.egg/turbogears/scheduler.pyR[’sN(RWRXRYRbR$R[(((sr/afs/athena.mit.edu/user/x/a/xavid/lib/python2.6/site-packages/TurboGears-1.1rc1-py2.6.egg/turbogears/scheduler.pyR‚s cBs;eZdZd„Zd„Zd„Zd„Zd„ZRS(s(A Scheduler that runs in its own thread.cCs ti|ƒtiƒ|_dS(N(R R$t threadingtLockt_lock(R#((sr/afs/athena.mit.edu/user/x/a/xavid/lib/python2.6/site-packages/TurboGears-1.1rc1-py2.6.egg/turbogears/scheduler.pyR$Ÿs cCs9tid|iƒ|_|iitƒ|iiƒdS(s4Splice off a thread in which the scheduler will run.ttargetN(RotThreadRHtthreadt setDaemonRRI(R#((sr/afs/athena.mit.edu/user/x/a/xavid/lib/python2.6/site-packages/TurboGears-1.1rc1-py2.6.egg/turbogears/scheduler.pyRI¤scCs8ti|ƒy|iiƒWntj onXdS(s5Stop the scheduler and wait for the thread to finish.N(R RKRtRRtAttributeError(R#((sr/afs/athena.mit.edu/user/x/a/xavid/lib/python2.6/site-packages/TurboGears-1.1rc1-py2.6.egg/turbogears/scheduler.pyRKªs  cCs|iiƒdS(sLock the thread's task queue.N(Rqtacquire(R#((sr/afs/athena.mit.edu/user/x/a/xavid/lib/python2.6/site-packages/TurboGears-1.1rc1-py2.6.egg/turbogears/scheduler.pyR.²scCs|iiƒdS(s,Release the lock on th ethread's task queue.N(Rqtrelease(R#((sr/afs/athena.mit.edu/user/x/a/xavid/lib/python2.6/site-packages/TurboGears-1.1rc1-py2.6.egg/turbogears/scheduler.pyR/¶s(RWRXRYR$RIRKR.R/(((sr/afs/athena.mit.edu/user/x/a/xavid/lib/python2.6/site-packages/TurboGears-1.1rc1-py2.6.egg/turbogears/scheduler.pyRœs     cBs eZdZd„Zd„ZRS(s:A mixin class to make a Task execute in a separate thread.cCs-tid|iƒiƒ|i|ƒƒdS(s*Execute the task action in its own thread.RrN(RoRst threadedcallRIR](R#R^((sr/afs/athena.mit.edu/user/x/a/xavid/lib/python2.6/site-packages/TurboGears-1.1rc1-py2.6.egg/turbogears/scheduler.pyR_¾scCs7y|iƒWn"tj o}|i|ƒnXdS(N(R[ROR\(R#RV((sr/afs/athena.mit.edu/user/x/a/xavid/lib/python2.6/site-packages/TurboGears-1.1rc1-py2.6.egg/turbogears/scheduler.pyRyÃs(RWRXRYR_Ry(((sr/afs/athena.mit.edu/user/x/a/xavid/lib/python2.6/site-packages/TurboGears-1.1rc1-py2.6.egg/turbogears/scheduler.pyR»s cBseZdZRS(s.Interval Task that executes in its own thread.(RWRXRY(((sr/afs/athena.mit.edu/user/x/a/xavid/lib/python2.6/site-packages/TurboGears-1.1rc1-py2.6.egg/turbogears/scheduler.pyR ËscBseZdZRS(s,Single Task that executes in its own thread.(RWRXRY(((sr/afs/athena.mit.edu/user/x/a/xavid/lib/python2.6/site-packages/TurboGears-1.1rc1-py2.6.egg/turbogears/scheduler.pyRÏscBseZdZRS(s-Weekday Task that executes in its own thread.(RWRXRY(((sr/afs/athena.mit.edu/user/x/a/xavid/lib/python2.6/site-packages/TurboGears-1.1rc1-py2.6.egg/turbogears/scheduler.pyRÓscBseZdZRS(s.Monthday Task that executes in its own thread.(RWRXRY(((sr/afs/athena.mit.edu/user/x/a/xavid/lib/python2.6/site-packages/TurboGears-1.1rc1-py2.6.egg/turbogears/scheduler.pyR ×stforkcBs2eZdZd„Zd„Zd„Zd„ZRS(s0A Scheduler that runs in its own forked process.cCs.t|dƒoti|itiƒndS(Ntchildpid(thasattrtostkillR{tsignaltSIGKILL(R#((sr/afs/athena.mit.edu/user/x/a/xavid/lib/python2.6/site-packages/TurboGears-1.1rc1-py2.6.egg/turbogears/scheduler.pyt__del__æscCs]tiƒ}|djo1titi|iƒ|iƒtidƒn||_|`dS(s7Fork off a new process in which the scheduler will run.iN( R}RzRtSIGUSR1t signalhandlerRHt_exitR{R(R#tpid((sr/afs/athena.mit.edu/user/x/a/xavid/lib/python2.6/site-packages/TurboGears-1.1rc1-py2.6.egg/turbogears/scheduler.pyRIês    cCs-ti|itiƒti|idƒdS(s6Stop the scheduler and wait for the process to finish.iN(R}R~R{RR‚twaitpid(R#((sr/afs/athena.mit.edu/user/x/a/xavid/lib/python2.6/site-packages/TurboGears-1.1rc1-py2.6.egg/turbogears/scheduler.pyRKøscCsti|ƒdS(N(R RK(R#tsigtstack((sr/afs/athena.mit.edu/user/x/a/xavid/lib/python2.6/site-packages/TurboGears-1.1rc1-py2.6.egg/turbogears/scheduler.pyRƒýs(RWRXRYRRIRKRƒ(((sr/afs/athena.mit.edu/user/x/a/xavid/lib/python2.6/site-packages/TurboGears-1.1rc1-py2.6.egg/turbogears/scheduler.pyRãs    cBseZdZd„ZRS(s;A mixin class to make a Task execute in a separate process.cCsqtiƒ}|djoDy|iƒWn"tj o}|i|ƒnXtidƒn|i|ƒƒdS(s+Execute the task action in its own process.iN(R}RzR[ROR\R„R](R#R^R…RV((sr/afs/athena.mit.edu/user/x/a/xavid/lib/python2.6/site-packages/TurboGears-1.1rc1-py2.6.egg/turbogears/scheduler.pyR_s  (RWRXRYR_(((sr/afs/athena.mit.edu/user/x/a/xavid/lib/python2.6/site-packages/TurboGears-1.1rc1-py2.6.egg/turbogears/scheduler.pyRscBseZdZRS(s/Interval Task that executes in its own process.(RWRXRY(((sr/afs/athena.mit.edu/user/x/a/xavid/lib/python2.6/site-packages/TurboGears-1.1rc1-py2.6.egg/turbogears/scheduler.pyRscBseZdZRS(s-Single Task that executes in its own process.(RWRXRY(((sr/afs/athena.mit.edu/user/x/a/xavid/lib/python2.6/site-packages/TurboGears-1.1rc1-py2.6.egg/turbogears/scheduler.pyRscBseZdZRS(s.Weekday Task that executes in its own process.(RWRXRY(((sr/afs/athena.mit.edu/user/x/a/xavid/lib/python2.6/site-packages/TurboGears-1.1rc1-py2.6.egg/turbogears/scheduler.pyRscBseZdZRS(s/Monthday Task that executes in its own process.(RWRXRY(((sr/afs/athena.mit.edu/user/x/a/xavid/lib/python2.6/site-packages/TurboGears-1.1rc1-py2.6.egg/turbogears/scheduler.pyRscCs$t}|ptƒ}|an|S(N(t_scheduler_instanceR(tsi((sr/afs/athena.mit.edu/user/x/a/xavid/lib/python2.6/site-packages/TurboGears-1.1rc1-py2.6.egg/turbogears/scheduler.pyt_get_scheduler%s   cCstƒ}|iƒdS(N(R‹RI(RŠ((sr/afs/athena.mit.edu/user/x/a/xavid/lib/python2.6/site-packages/TurboGears-1.1rc1-py2.6.egg/turbogears/scheduler.pyt_start_scheduler-s cCs#tpdStƒ}|iƒdS(N(R‰R‹RK(RŠ((sr/afs/athena.mit.edu/user/x/a/xavid/lib/python2.6/site-packages/TurboGears-1.1rc1-py2.6.egg/turbogears/scheduler.pyt_stop_scheduler1s icCs=tƒ}|id|d|d|d|d|d|d|ƒS(NR2R5R7R8R4R6R3(R‹R(R2R5R7R8R4R6R3RŠ((sr/afs/athena.mit.edu/user/x/a/xavid/lib/python2.6/site-packages/TurboGears-1.1rc1-py2.6.egg/turbogears/scheduler.pyR7s c Cs7tƒ}|id|d|d|d|d|d|ƒS(NR2R7R8R4R6R3(R‹R(R2R7R8R4R6R3RŠ((sr/afs/athena.mit.edu/user/x/a/xavid/lib/python2.6/site-packages/TurboGears-1.1rc1-py2.6.egg/turbogears/scheduler.pyR>s  cCsCtƒ}|id|d|d|ddd|d|d|d|ƒS( NR2R3R=R>R?R6R7R8(R‹RARb(R2R=R?R7R8R6R3RŠ((sr/afs/athena.mit.edu/user/x/a/xavid/lib/python2.6/site-packages/TurboGears-1.1rc1-py2.6.egg/turbogears/scheduler.pyREs cCsCtƒ}|id|d|ddd|d|d|d|d|ƒS( NR2R3R=R>R?R6R7R8(R‹RARb(R2R>R?R7R8R6R3RŠ((sr/afs/athena.mit.edu/user/x/a/xavid/lib/python2.6/site-packages/TurboGears-1.1rc1-py2.6.egg/turbogears/scheduler.pyRLs cCstƒ}|i|ƒdS(N(R‹R(R:RŠ((sr/afs/athena.mit.edu/user/x/a/xavid/lib/python2.6/site-packages/TurboGears-1.1rc1-py2.6.egg/turbogears/scheduler.pyRSs ((((((-RYt__all__R}RPRR!RSRCtturbogears.utilRRR R R RRRRRoRRR RRR t ImportErrorR|RRRRRRRRbR‰R‹RŒRRRRRRR(((sr/afs/athena.mit.edu/user/x/a/xavid/lib/python2.6/site-packages/TurboGears-1.1rc1-py2.6.egg/turbogears/scheduler.pyt(sŽ        º" #