gUdZddlmZddlZddlmZddlmZmZddl m Z ddl m Z ddl mZe eZd ed <d Zd ed <d Zd ed<GddZy)z.A class that watches a given path via polling.) annotationsN)ThreadPoolExecutor)CallableFinal) get_loggerrepr_)utilr_LOGGER _MAX_WORKERSg?_POLLING_PERIOD_SECScveZdZdZeeZed dZddd d dZ ddZ d d Z d d Z d d Z y)PollingPathWatcherz*Watches a path on disk via a polling loop.) max_workersc.tjdy)zClose top-level watcher object. This is a no-op, and exists for interface parity with EventBasedPathWatcher. zWatcher closedN)r debug[/var/www/openai/venv/lib/python3.12/site-packages/streamlit/watcher/polling_path_watcher.py close_allzPollingPathWatcher.close_all&s  &'rNF glob_patternallow_nonexistentc>||_||_||_||_d|_t j |j|j|_t j|j|j|j|_ |jy)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)selfpath on_changedrrs r__init__zPollingPathWatcher.__init__/s %)"3 "&"="= JJ//# 77 JJ++"55  rct|SNrr&s r__repr__zPollingPathWatcher.__repr__Ps T{rcNfd}tjj|y)NcXtjtjyr+)timesleepr_check_if_path_changedr,srtaskz*PollingPathWatcher._schedule..taskTs JJ+ ,  ' ' )r)r _executorsubmit)r&r3s` rr%zPollingPathWatcher._scheduleSs * $$++D1rc|jsytj|j|j}|dk7r ||j kr|j y||_tj|j|j|j}||jk(r|j y||_ tjd|j|j|j|j y)NgrzChange detected: %s) r r r!rrr"r%r#rr$r rr)r&modification_timemd5s rr2z)PollingPathWatcher._check_if_path_changedZs||  77 JJ//   #(9T=T=T(T NN  "311 JJ++"55  $))  NN    +TZZ8 $ rcd|_y)zStop watching the file system.FN)r r,s rclosezPollingPathWatcher.closezs  r)returnNone) r'strr(zCallable[[str], None]rz str | Nonerboolr;r<)r;r=)__name__ __module__ __qualname____doc__rr r4 staticmethodrr)r-r%r2r:rrrrr!st4"|rKsO5" 1"' "H%% e!e![[r