,h; ddlZddlZddlZddlZddlmZddlmZddlm Z m Z m Z m Z m Z mZmZmZddlZddlmZddlmZdZej.d ZGd d eZeeefZ e r?ddlZdd lmZddlZeej>ej>ej>fZ Gd deZ!edddddddddddd deeefde e d ege"fde#de#de dde#de"de e"de"de e"d e#d!e"d"e e"d#e eeddffd$Z$edddddddddddd deeefde e eege"fde#de#de d%de e#de"de e"de e"de e"d e#d!e"d"e e"d#e eedffd&Z%d'eee#efde e eege"fd#eefd(Z&d)eed#dfd*Z'd+e e#d#e#fd,Z(de e"d#e"fd-Z)d e#d#e#fd.Z*de e"d#e"fd/Z+d#e"fd0Z,d"e e"d#e"fd1Z-y)2N)IntEnum)Path) TYPE_CHECKINGAsyncGeneratorCallable GeneratorOptionalSetTupleUnion) RustNotify) DefaultFilter)watchawatchChange FileChangezwatchfiles.mainc.eZdZdZdZ dZ dZ defdZy)rz= Enum representing the type of change that occurred. r returnc|jSN)nameselfs Q/var/www/html/Resume-Scraper/venv/lib/python3.12/site-packages/watchfiles/main.pyraw_strzChange.raw_strs yyN) __name__ __module__ __qualname____doc__addedmodifieddeletedstrrrrrrs- E,HTG*rr)ProtocolceZdZdefdZy) AbstractEventrcyrr(rs ris_setzAbstractEvent.is_set1srN)r r!r"boolr-r(rrr+r+0s %D%rr+i@2FTi,) watch_filterdebouncestep stop_event rust_timeoutyield_on_timeoutdebugraise_interrupt force_polling poll_delay_ms recursiveignore_permission_deniedpathsr1r2r3r4r5r6r7r8r9r:r;r<rc '2Kt|}t| } t| } t|}t | D cgc] } t | c} ||| | | 5} |j ||||}|dk(r%|r tntjdno|dk(r'|rttjd dddy|dk(r dddyt||}|rt||ntjd|cc} w#1swYyxYww)a5 Watch one or more paths and yield a set of changes whenever files change. The paths watched can be directories or files, directories are watched recursively - changes in subdirectories are also detected. #### Force polling Notify will fall back to file polling if it can't use file system notifications, but we also force Notify to use polling if the `force_polling` argument is `True`; if `force_polling` is unset (or `None`), we enable force polling thus: * if the `WATCHFILES_FORCE_POLLING` environment variable exists and is not empty: * if the value is `false`, `disable` or `disabled`, force polling is disabled * otherwise, force polling is enabled * otherwise, we enable force polling only if we detect we're running on WSL (Windows Subsystem for Linux) It is also possible to change the poll delay between iterations, it can be changed to maintain a good response time and an appropiate CPU consumption using the `poll_delay_ms` argument, we change poll delay thus: * if file polling is enabled and the `WATCHFILES_POLL_DELAY_MS` env var exists and it is numeric, we use that * otherwise, we use the argument value Args: *paths: filesystem paths to watch. watch_filter: callable used to filter out changes which are not important, you can either use a raw callable or a [`BaseFilter`][watchfiles.BaseFilter] instance, defaults to an instance of [`DefaultFilter`][watchfiles.DefaultFilter]. To keep all changes, use `None`. debounce: maximum time in milliseconds to group changes over before yielding them. step: time to wait for new changes in milliseconds, if no changes are detected in this time, and at least one change has been detected, the changes are yielded. stop_event: event to stop watching, if this is set, the generator will stop iteration, this can be anything with an `is_set()` method which returns a bool, e.g. `threading.Event()`. rust_timeout: maximum time in milliseconds to wait in the rust code for changes, `0` means no timeout. yield_on_timeout: if `True`, the generator will yield upon timeout in rust even if no changes are detected. debug: whether to print information about all filesystem changes in rust to stdout, if `None` will use the `WATCHFILES_DEBUG` environment variable. raise_interrupt: whether to re-raise `KeyboardInterrupt`s, or suppress the error and just stop iterating. force_polling: See [Force polling](#force-polling) above. poll_delay_ms: delay between polling for changes, only used if `force_polling=True`. recursive: if `True`, watch for changes in sub-directories recursively, otherwise watch only for changes in the top-level directory, default is `True`. ignore_permission_denied: if `True`, will ignore permission denied errors, otherwise will raise them by default. Setting the `WATCHFILES_IGNORE_PERMISSION_DENIED` environment variable will set this value too. Yields: The generator yields sets of [`FileChange`][watchfiles.main.FileChange]s. ```py title="Example of watch usage" from watchfiles import watch for changes in watch('./first/dir', './second/dir', raise_interrupt=False): print(changes) ``` timeoutrust notify timeout, continuingsignalz(KeyboardInterrupt caught, stopping watchNstop(all changes filtered out, raw_changes=%s)_default_force_polling_default_poll_delay_ms!_default_ignore_permission_denied_default_debugrr'rsetloggerr7KeyboardInterruptwarning _prep_changes _log_changes)r1r2r3r4r5r6r7r8r9r:r;r<r=pwatcher raw_changeschangess rrr4s L+=9M*=9M@AYZ 5 !E AQ }iQi Z !--$ jQKi'#%KLL!BC("++NN#MNZZ &#ZZ&( \B )!MLL!K[Y+ ZZsA6DD DA#D 9 DD  D5D D DDAnyEventc K|tjdt|tj} n|} t |}t | } t| } t|}t| Dcgc] }t|c}||| | | 5}t|}tj} tj4d{} tjj|j |||| d{}|j&j)dddd{dk(r&|rt%njt*j-dnT|dk(r dddy|dk(r t/dt1||}|rt3||nt*j-d|cc}w77#|t"f$r| j%wxYw7#1d{7swYxYw#1swYyxYww) a^ Asynchronous equivalent of [`watch`][watchfiles.watch] using threads to wait for changes. Arguments match those of [`watch`][watchfiles.watch] except `stop_event`. All async methods use [anyio](https://anyio.readthedocs.io/en/latest/) to run the event loop. Unlike [`watch`][watchfiles.watch] `KeyboardInterrupt` cannot be suppressed by `awatch` so they need to be caught where `asyncio.run` or equivalent is called. Args: *paths: filesystem paths to watch. watch_filter: matches the same argument of [`watch`][watchfiles.watch]. debounce: matches the same argument of [`watch`][watchfiles.watch]. step: matches the same argument of [`watch`][watchfiles.watch]. stop_event: `anyio.Event` which can be used to stop iteration, see example below. rust_timeout: matches the same argument of [`watch`][watchfiles.watch], except that `None` means use `1_000` on Windows and `5_000` on other platforms thus helping with exiting on `Ctrl+C` on Windows, see [#110](https://github.com/samuelcolvin/watchfiles/issues/110). yield_on_timeout: matches the same argument of [`watch`][watchfiles.watch]. debug: matches the same argument of [`watch`][watchfiles.watch]. raise_interrupt: This is deprecated, `KeyboardInterrupt` will cause this coroutine to be cancelled and then be raised by the top level `asyncio.run` call or equivalent, and should be caught there. See [#136](https://github.com/samuelcolvin/watchfiles/issues/136) force_polling: if true, always use polling instead of file system notifications, default is `None` where `force_polling` is set to `True` if the `WATCHFILES_FORCE_POLLING` environment variable exists. poll_delay_ms: delay between polling for changes, only used if `force_polling=True`. `poll_delay_ms` can be changed via the `WATCHFILES_POLL_DELAY_MS` environment variable. recursive: if `True`, watch for changes in sub-directories recursively, otherwise watch only for changes in the top-level directory, default is `True`. ignore_permission_denied: if `True`, will ignore permission denied errors, otherwise will raise them by default. Setting the `WATCHFILES_IGNORE_PERMISSION_DENIED` environment variable will set this value too. Yields: The generator yields sets of [`FileChange`][watchfiles.main.FileChange]s. ```py title="Example of awatch usage" import asyncio from watchfiles import awatch async def main(): async for changes in awatch('./first/dir', './second/dir'): print(changes) if __name__ == '__main__': try: asyncio.run(main()) except KeyboardInterrupt: print('stopped via KeyboardInterrupt') ``` ```py title="Example of awatch usage with a stop event" import asyncio from watchfiles import awatch async def main(): stop_event = asyncio.Event() async def stop_soon(): await asyncio.sleep(3) stop_event.set() stop_soon_task = asyncio.create_task(stop_soon()) async for changes in awatch('/path/to/dir', stop_event=stop_event): print(changes) # cleanup by awaiting the (now complete) stop_soon_task await stop_soon_task asyncio.run(main()) ``` Nzraise_interrupt is deprecated, KeyboardInterrupt will cause this coroutine to be cancelled and then be raised by the top level asyncio.run call or equivalent, and should be caught there. See #136.r?r@rBrAz+watch thread unexpectedly received a signalrC)warningswarnDeprecationWarninganyioEventrDrErFrGrr'_calc_async_timeoutget_cancelled_exc_classcreate_task_group to_threadrun_syncrrJrH cancel_scopecancelrIr7 RuntimeErrorrLrM)r1r2r3r4r5r6r7r8r9r:r;r<r= stop_event_rNrOr?CancelledErrortgrPrQs rrrsn"  o   %  *=9M*=9M@AYZ 5 !E AQ }iQi  Z %l3668..0 ) )B(-(@(@PXZ^`git(u"uK &&( ) )i'#%KLL!BC&- Z Z.("#PQQ' \B )!MLL!K[Y5  )"u&(9:OO% ) ) ) ) Z ZsA+G5-F)? G5 9G)F.G)G 0F2:F0;F2?G G)$G%5G) G5#AG))G5.G)0F22GGG)G& GG& "G))G2.G5rPc|Dchc]\}}t||f}}}|r|Dchc]}||d|ds|}}|Scc}}wcc}w)Nrr )r)rPr1changepathrQcs rrLrL#sZ;FF,&$v%FGF%BadAaD)A1BB NGBsAA A rQctjtjrht |}|dk(rdnd}tjtj rtj d|||ytjd||yy)Nr sz%d change%s detected: %sz%d change%s detected)rI isEnabledForloggingINFOlenDEBUGr7info)rQcountplurals rrMrM-se 7<<(G zs   w}} - LL3UFG L KK.v > )rr?c4|tjdk(ryy|S)zC see https://github.com/samuelcolvin/watchfiles/issues/110 win32ir0)sysplatform)r?s rrYrY7s  <<7 "rcp||Stjd}|r|jdvStS)z See docstring for `watch` above for details. See samuelcolvin/watchfiles#167 and samuelcolvin/watchfiles#187 for discussion and rationale. WATCHFILES_FORCE_POLLING>falsedisabledisabled)osgetenvlower_auto_force_polling)r9env_vars rrDrDDs=  ii23G}}&FFF"$$rcjtjd}|r|jr t|S|S)z6 See docstring for `watch` above for details. WATCHFILES_POLL_DELAY_MS)r|r} isdecimalint)r:rs rrErESs1ii23G7$$&7|rcJ||Stjd}t|S)NWATCHFILES_DEBUGr|r}r.)r7rs rrGrG^s&  ii*+G =rcddl}|j}d|jjvxr|jjdk(S)z Whether to auto-enable force polling, it should be enabled automatically only on WSL. See samuelcolvin/watchfiles#187 for discussion. rNzmicrosoft-standardlinux)rvunamereleaser~system)rvrs rrresC  NN E 5==#6#6#8 8 \U\\=O=O=QU\=\\rcJ||Stjd}t|S)N#WATCHFILES_IGNORE_PERMISSION_DENIEDr)r<rs rrFrFqs'+''ii=>G =r).rlr|rurTenumrpathlibrtypingrrrrr r r r rW _rust_notifyrfiltersr__all__ getLoggerrIrr'rasyncior)triorXrRr+r.rrrrLrMrYrDrErGrrFr(rrrs bbb $" 3   , - W  63;   U[['--;bZbZD>bZbZbZ'tnbZs:d*+bZN=JO'+"&" &*$(/3GZ $) GZ8VSM4$789GZGZ  GZ $ GZ 3- GZGZ D>GZd^GZD>GZGZGZ'tnGZC OT)*GZTU38_%5=hPS}VZGZ>[5\_?#j/?d? # 3  %(4. %T %##(4.T ]T ]SWr