o /i@sddlZddlZddlZGdddeZGdddeZGdddeZGdd d ZGd d d eZGd d d eZ de efddZ dS)Nc@eZdZdZdS)BaseTimeoutExceptionzBase exception for timeouts.N__name__ __module__ __qualname____doc__r r K/var/www/html/flask_server/venv/lib/python3.10/site-packages/rq/timeouts.pyrsrc@r)JobTimeoutExceptionz[Raised when a job takes longer to complete than the allowed maximum timeout value. Nrr r r r r r c@r)HorseMonitorTimeoutExceptionz]Raised when waiting for a horse exiting takes longer than the maximum timeout value. Nrr r r r r r r c@s<eZdZdZefddZddZddZdd Zd d Z d S) BaseDeathPenaltyz!Base class to setup job timeouts.cKs||_||_dSN)_timeout _exception)selftimeout exceptionkwargsr r r __init__s zBaseDeathPenalty.__init__cCs |dSr)setup_death_penaltyrr r r __enter__#s zBaseDeathPenalty.__enter__cCs$z|WdStyYdSw)NF)cancel_death_penaltyr)rtypevalue tracebackr r r __exit__&s  zBaseDeathPenalty.__exit__cCtrNotImplementedErrorrr r r r6z$BaseDeathPenalty.setup_death_penaltycCrrr rr r r r9r"z%BaseDeathPenalty.cancel_death_penaltyN) rrrrrrrrrrr r r r rs  rc@s$eZdZddZddZddZdS)UnixSignalDeathPenaltycCs|d|jdNz%Task exceeded maximum timeout value (z seconds))rr)rsignumframer r r handle_death_penalty>sz+UnixSignalDeathPenalty.handle_death_penaltycCs ttj|jt|jdS)zSets up an alarm signal and a signal handler that raises an exception after the timeout amount (expressed in seconds). N)signalSIGALRMr'alarmrrr r r rAsz*UnixSignalDeathPenalty.setup_death_penaltycCstdttjtjdS)zgRemoves the death penalty alarm and puts back the system into default signal handling. rN)r(r*r)SIG_DFLrr r r rHs z+UnixSignalDeathPenalty.cancel_death_penaltyN)rrrr'rrr r r r r#=s r#cs@eZdZeffdd ZddZddZddZd d ZZ S) TimerDeathPenaltyc sDtjfi|tj|_d|_fdd}||j_dS)Ncst|dddSr$)superr)rargsr) __class__rrr r init_with_messageXsz5TimerDeathPenalty.__init__..init_with_message)r-r threadingcurrent_threadident_target_thread_id_timerr)rrrrr0r/)rrr rQs   zTimerDeathPenalty.__init__cCst|j|jS)z7Returns a new timer since timers can only be used once.)r1Timerrr'rr r r new_timer]szTimerDeathPenalty.new_timercCs`tjt|jt|j}|dkrtd|j|dkr.tjt|jdtddS)zRaises an asynchronous exception in another thread. Reference http://docs.python.org/c-api/init.html#PyThreadState_SetAsyncExc for more info. rzInvalid thread ID z PyThreadState_SetAsyncExc failedN) ctypes pythonapiPyThreadState_SetAsyncExcc_longr4 py_objectr ValueError SystemError)rretr r r r'asz&TimerDeathPenalty.handle_death_penaltycCs&|jdkrdS||_|jdS)zStarts the timer.rN)rr8r5startrr r r ros  z%TimerDeathPenalty.setup_death_penaltycCs"|jdkrdS|jd|_dS)zCancels the timer.rN)rr5cancelrr r r rvs   z&TimerDeathPenalty.cancel_death_penalty) rrrr rr8r'rr __classcell__r r r6r r,Ps  r,returncCsttdrtStS)z>Returns the default death penalty class based on the platform.r))hasattrr(r#r,r r r r get_default_death_penalty_class~s rG) r:r(r1 Exceptionrr r rr#r,rrGr r r r s!.