o Zh@sUdZddlmZddlZddlmZddlmZddlm Z m Z ddl m Z ddl mZdd lmZdd lmZeeZd ed <d Zd ed<dZd ed<GdddZdS)z.A class that watches a given path via polling.) annotationsN)ThreadPoolExecutor)Path)CallableFinal)StreamlitMaxRetriesError) get_loggerrepr_)utilr_LOGGER _MAX_WORKERSg?_POLLING_PERIOD_SECSc@sbeZdZdZeedZedddZddd dddZ dddZ dddZ dddZ dddZ dS)PollingPathWatcherz*Watches a path on disk via a polling loop.) max_workersreturnNonecCstddS)zClose top-level watcher object. This is a no-op, and exists for interface parity with EventBasedPathWatcher. zWatcher closedN)r debugrrg/var/www/html/Persson_Maskin/env/lib/python3.10/site-packages/streamlit/watcher/polling_path_watcher.py close_all(szPollingPathWatcher.close_allNF glob_patternallow_nonexistentpathstr on_changedCallable[[str], None]r str | NonerboolcCs`t||_||_||_||_d|_tt|j|j|_ tj t|j|j|jd|_ | dS)zConstructor. You do not need to retain a reference to a PollingPathWatcher to prevent it from being garbage collected. (The global _executor object retains references to all active instances.) TrN) r_path _on_changed _glob_pattern_allow_nonexistent_activer path_modification_timer_modification_timecalc_md5_with_blocking_retries_md5 _schedule)selfrrrrrrr__init__1s   zPollingPathWatcher.__init__cCst|SNr r+rrr__repr__RszPollingPathWatcher.__repr__csdfdd }tj|dS)NrrcsttdSr-)timesleepr_check_if_path_changedrr.rrtaskVs  z*PollingPathWatcher._schedule..taskrr)r _executorsubmit)r+r3rr.rr*UszPollingPathWatcher._schedulec Cs|jsdSz8tt|j|j}|dkr ||jkr |WdS||_tjt|j|j |jd}||j kr<|WdSWnt yY}zt j d|j|dWYd}~dSd}~ww||_ t d|j|t|j|dS)Ngrz9Ignoring file change. Failed to calculate MD5 for path %s)exc_infozChange detected: %s)r%r r&rr!r$r'r*r(r#r)rr rr")r+modification_timemd5exrrrr2\sB    z)PollingPathWatcher._check_if_path_changedcCs d|_dS)zStop watching the file system.FN)r%r.rrrcloses zPollingPathWatcher.closer4) rrrrrrrr rr)rr)__name__ __module__ __qualname____doc__rrr5 staticmethodrr,r/r*r2r;rrrrr#s    !  +r)r? __future__rr0concurrent.futuresrpathlibrtypingrrstreamlit.errorsrstreamlit.loggerrstreamlit.utilr streamlit.watcherr r<r __annotations__rrrrrrrs