/usr/lib/python2.6/site-packages/boto/manage
Edit: /usr/lib/python2.6/site-packages/boto/manage/task.pyo (6548B)
Ñò
Å-õSc
@ s¥ d d k Z d d k l Z l Z l Z d d k l Z d d k Z d d k Z d d k Z d d k
l Z d „ Z d e f d „ ƒ YZ
d e f d „ ƒ YZ d S(
iÿÿÿÿN( t StringPropertyt DateTimePropertyt IntegerProperty( t Model( t StringIOc C sF | d j o d St | ƒ d j p t | ƒ d j o
t ‚ n d S( Nt *i i ( t intt
ValueError( t val( ( s4 /usr/lib/python2.6/site-packages/boto/manage/task.pyt
check_hour s
&t Taskc B s§ e Z d Z e ƒ Z e d e d e d d ƒ Z e d e ƒ Z e ƒ Z
e ƒ Z e ƒ Z
e ƒ Z e d „ ƒ Z d d „ Z d „ Z d „ Z d d
„ Z d „ Z RS(
sç
A scheduled, repeating task that can be executed by any participating servers.
The scheduling is similar to cron jobs. Each task has an hour attribute.
The allowable values for hour are [0-23|*].
To keep the operation reasonably efficient and not cause excessive polling,
the minimum granularity of a Task is hourly. Some examples:
hour='*' - the task would be executed each hour
hour='3' - the task would be executed at 3AM GMT each day.
t requiredt validatort defaultR c C s( x! | i ƒ D] } | i | ƒ q
Wd S( N( t allt start( t clst
queue_namet task( ( s4 /usr/lib/python2.6/site-packages/boto/manage/task.pyt start_all9 s
c K sS t t | ƒ i | | | i d j | _ | i d j | _ t i i ƒ | _ d S( NR ( t superR
t __init__t hourt hourlyt dailyt datetimet utcnowt now( t selft idt kw( ( s4 /usr/lib/python2.6/site-packages/boto/manage/task.pyR > s c C sk t i i d | i | i | i f ƒ | i o | i o d S| i ok | i o` t | i ƒ | i i j o d St
t | i ƒ | i i | i i t | i ƒ ƒ d d Sn | i | i } | i o$ | i d j o d Sd | i Snu t | i ƒ | i i j o | i d j o d Sd Sn< t
t | i ƒ | i i | i i t | i ƒ ƒ d d Sd S( sg
Determine how long until the next scheduled time for a Task.
Returns the number of seconds until the next scheduled time or zero
if the task needs to be run immediately.
If it's an hourly task and it's never been run, run it now.
If it's a daily task and it's never been run and the hour is right, run it now.
s! checking Task[%s]-now=%s, last=%si i< i ipC Ni i (
t botot logt infot nameR t
last_executedR R R R t maxt secondst days( R t delta( ( s4 /usr/lib/python2.6/site-packages/boto/manage/task.pyt checkD s" & ?
c
C s‡ t i i d | i | i f ƒ t ƒ } t i | i d t d t i d t i d t i ƒ} d } | } x™ | i
ƒ d j o… t i i d | | f ƒ | | j oC | | 7} t i i d | i | f ƒ | o | i | ƒ qè n t
i d ƒ | d 7} qk W| i ƒ } | i | d ƒ | i | d
ƒ t i i d | i | i ƒ f ƒ | i | _ | i | _ | i ƒ d d !| _ d S(
Ns Task[%s] - running:%st shellt stdint stdoutt stderri s nsecs=%s, timeout=%ss( Task[%s] - setting timeout to %d secondsi i s Task[%s] - output: %siÿ ( R R R! R" t commandR t
subprocesst Popent Truet PIPEt pollt Nonet change_visibilityt timet sleept communicatet writet getvalueR R# t
returncodet last_statust last_output( R t msgt vtimeoutt log_fpt processt nsecst current_timeoutt t( ( s4 /usr/lib/python2.6/site-packages/boto/manage/task.pyt _runf s.
# i< c C sù | i ƒ } t i i d | i | f ƒ | d j ož | i | | ƒ | i } | i | i ƒ } | i | ƒ } | i | _
| i ƒ t i i d | i | i f ƒ | i ƒ t i i d | i | i f ƒ n" t i i d | ƒ | i
| ƒ d S( Ns Task[%s] - delay=%s secondsi s Task[%s] - new message id=%ss Task[%s] - deleted message %ss new_vtimeout: %d( R( R R R! R" RD t queuet new_messageR R8 t
message_idt putt deleteR4 ( R R= R> t delayRE t new_msg( ( s4 /usr/lib/python2.6/site-packages/boto/manage/task.pyt run~ s
$c C s t i i d | i | f ƒ t i d | ƒ } | i | i ƒ } | i | ƒ } | i | _ | i ƒ t i i d | i ƒ d S( Ns" Task[%s] - starting with queue: %st sqss Task[%s] - start successful(
R R R! R" t lookupRF R R8 RG RH ( R R RE R= ( ( s4 /usr/lib/python2.6/site-packages/boto/manage/task.pyR s
N( t __name__t
__module__t __doc__R R" R0 R R R- R R# R R; R< RG t classmethodR R3 R R( RD RL R ( ( ( s4 /usr/lib/python2.6/site-packages/boto/manage/task.pyR
# s
" t
TaskPollerc B s e Z d „ Z d d d „ Z RS( c C s( t i ƒ | _ | i i | ƒ | _ d S( N( R t connect_sqsRM RN RE ( R R ( ( s4 /usr/lib/python2.6/site-packages/boto/manage/task.pyR š s i< c C sÆ x¿ t o· | i i | ƒ } | o t i | i ƒ ƒ } | om | i p | i | i j o4 t i i
d | i | i f ƒ | i | | ƒ q¬ t i i
d | i ƒ q½ q t
i | ƒ q Wd S( Ns Task[%s] - read message %ss- Task[%s] - found extraneous message, ignoring( R0 RE t readR
t get_by_idt get_bodyRG R R R R! R" RL R5 R6 ( R t waitR> t mR ( ( s4 /usr/lib/python2.6/site-packages/boto/manage/task.pyR2 ž s ( RO RP R R2 ( ( ( s4 /usr/lib/python2.6/site-packages/boto/manage/task.pyRS ˜ s ( R t boto.sdb.db.propertyR R R t boto.sdb.db.modelR R R. R5 t boto.compatR R R
t objectRS ( ( ( s4 /usr/lib/python2.6/site-packages/boto/manage/task.pyt
s $ u