o 沪g@sUdZddlmZddlZddlmZddlmZmZddl m Z ddl m Z ddl mZe eZd ed <d Zd ed <d Zd ed<GdddZdS)z.A class that watches a given path via polling.) annotationsN)ThreadPoolExecutor)CallableFinal) 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 debugrrb/var/www/html/chatdoc2/venv/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 | NonerboolcCsT||_||_||_||_d|_t|j|j|_tj|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) _path _on_changed _glob_pattern_allow_nonexistent_activer path_modification_time_modification_timecalc_md5_with_blocking_retries_md5 _schedule)selfrrrrrrr__init__/s zPollingPathWatcher.__init__cCst|SNrr)rrr__repr__PszPollingPathWatcher.__repr__csfdd}tj|dS)NcsttdSr+)timesleepr _check_if_path_changedrr,rrtaskTs  z*PollingPathWatcher._schedule..task)r _executorsubmit)r)r1rr,rr(Ss zPollingPathWatcher._schedulecCs|jsdSt|j|j}|dkr||jkr|dS||_tj|j|j|jd}||j kr5|dS||_ t d|j| |j|dS)NgrzChange detected: %s) r#r r$rr"r%r(r&r!r'r rr )r)modification_timemd5rrrr0Zs*   z)PollingPathWatcher._check_if_path_changedcCs d|_dS)zStop watching the file system.FN)r#r,rrrclosezs zPollingPathWatcher.close)rr) rrrrrrrrrr)rr)__name__ __module__ __qualname____doc__rr r2 staticmethodrr*r-r(r0r6rrrrr!s    !   r)r: __future__rr.concurrent.futuresrtypingrrstreamlit.loggerrstreamlit.utilrstreamlit.watcherr r7r __annotations__r r rrrrrs