d BddlZddlZddlmZddlmZGddeZy)N)logger)ustrc^eZdZdZej dZdZdZdZ dZ e dZ y ) PeriodicOperationz Instances of PeriodicOperation are tasks that are executed only after the given time period has elapsed. NOTE: the run() method catches any exceptions raised by the operation and logs them as warnings. <)minutesc |jj|_t|tj r|nt j ||_tjj|_d|_ d|_ y)N)seconds) __class____name___name isinstancedatetime timedelta_periodutcnow_next_run_time _last_warning_last_warning_time)selfperiods G/usr/lib/python3/dist-packages/azurelinuxagent/ga/periodic_operation.py__init__zPeriodicOperation.__init__$s^^^,, !+FH4F4F!GvXM_M_hnMo &//668!"&c. |jtjjkrb tjd|j |j tjj|jz|_yy#tjj|jz|_wxYw#t$r}dj|j t|}||jk7sD|j8tjj|j|jzk\rDtj|tjj|_ ||_ Yd}~yYd}~yd}~wwxYw)NzExecuting {0}...zKError in {0}: {1} --- [NOTE: Will not log the same error for the next hour])rrrrverboser _operationr Exceptionformatrrr_LOG_WARNING_PERIODwarn)rewarnings rrunzPeriodicOperation.run+sT -""h&7&7&>&>&@@TNN#5tzzBOO%*2*;*;*B*B*Dt||*SD' A +3*;*;*B*B*Dt||*SD' -cjjkokukuw{|}w~G$,,,0G0G0OS[SdSdSkSkSmqurIrILPLdLdrdTd G$*2*;*;*B*B*D'%,""Td -s/+C0B0C2CC FB7FFc|jS)N)rrs r next_run_timezPeriodicOperation.next_run_time:s"""rct)zn Derived classes must override this with the definition of the operation they need to perform )NotImplementedErrorr&s rrzPeriodicOperation._operation=s "##rc8t|Dcgc]}|jc}}|tjjz }|jdzdz|j zdz|j zdz }|dkDrtj|yycc}w)z Takes a list of operations, finds the operation that should be executed next (that with the closest next_run_time) and sleeps until it is time to execute that operation. ig.ArN) minr'rrdaysr microsecondstimesleep) operationsopnext_operation_timesleep_timedelta sleep_secondss rsleep_until_next_operationz,PeriodicOperation.sleep_until_next_operationCs " "K"2#3#3#5"KL-0A0A0H0H0JJ)..3d:_=T=TTXaadseAeAAENN 1  JJ} %  #LsBN) r __module__ __qualname____doc__rrr rr$r'r staticmethodr6rrrrsD-(,,R8' -#$  & &rr)rr/azurelinuxagent.commonrazurelinuxagent.common.futurerobjectrr;rrr?s$ ).7&7&r