gddlmZddlZddlmZddlmZer ddlZddlmZeje Z GddeZ y)) annotationsN) TYPE_CHECKING) BaseThread)Callablec(eZdZdfd ZddZxZS)ProcessWatcherc>t|||_||_y)N)super__init__ popen_objprocess_termination_callback)selfr r __class__s S/var/www/openai/venv/lib/python3.12/site-packages/watchdog/utils/process_watcher.pyr zProcessWatcher.__init__s ",H)cb|jj8|jjdry|jj8 |jj s|j r|j yyy#t $rtjdYywxYw)Ng?)timeoutz*Error calling process termination callback) r poll stopped_eventwaitis_setr Exceptionlogger exception)rs rrunzProcessWatcher.runsnn!!#+!!&&s&3nn!!#+ K%%,,.43T3T1134U. K   I J Ks6B B.-B.)r zsubprocess.Popenr zCallable[[], None] | NonereturnNone)rr)__name__ __module__ __qualname__r r __classcell__)rs@rrrsI Krr) __future__rloggingtypingrwatchdog.utilsr subprocessr getLoggerrrrrrr)s:" %   8 $KZKr