U ={f;@sHddlZddlZddlZddlZddlZddlZddlZddlZddlZddl m Z ddl m Z ddl mZddlmZddlmZddlmZmZmZmZmZmZmZmZmZmZddlZdd lm Z dd l!m"Z"m#Z#m$Z$m%Z%erdd lm&Z&d Z'e(d Z)dddde ddddddddd eee*fee*edeffeedfeee*efdeeee#gdfeee"e*ge+fe,e-e-e+e-e-e+e+e-dddZ.dddde ddddddd eee*fee*edeffeedfeee*efdeeee#gefeee"e*ge+fe,e-e-e+e+e+e-dddZ/e dZ0e*ee*d d!d"Z1d>ee*edeffd#eedfeee*efeee#d$d%d&d'Z2ee*edeffd#d(d)d*Z3Gd+d$d$Z4e*ee*eedfee*efdd,d-d.Z5e*ed/d0d1Z6ee*d2d3d4Z7ej8ee*ed5d6d7d8Z9e-edd9d:d;Z:dd2dsz!start_process..WATCHFILES_CHANGESfunction)r.r r!z-ignoring args and kwargs for "command" targetz+target must be a string to run as a command)jsondumpsosenviron isinstancestr get_tty_path run_function spawn_contextProcessstartr2warningAssertionErrorrH subprocessPopenrI) r.r"r r!r8Zchanges_env_varZtarget_r6 popen_argsrrr9r4s&     r4)r.r/cCs4t|tsdS|drdStd|r,dSdSdS)a^ Used by [`run_process`][watchfiles.run_process], [`arun_process`][watchfiles.arun_process] and indirectly the CLI to determine the target type with `target_type` is `auto`. Detects the target type - either `function` or `command`. This method is only called with `target_type='auto'`. The following logic is employed: * If `target` is not a string, it is assumed to be a function * If `target` ends with `.py` or `.sh`, it is assumed to be a command * Otherwise, the target is assumed to be a function if it matches the regex `[a-zA-Z0-9_]+(\.[a-zA-Z0-9_]+)+` If this logic does not work for you, specify the target type explicitly using the `target_type` function argument or `--target-type` command line argument. Args: target: The target value Returns: either `'function'` or `'command'` rO)z.pyz.shcommandz[a-zA-Z0-9_]+(\.[a-zA-Z0-9_]+)+N)rTrUendswithre fullmatch)r.rrr9rs   rc@steZdZddddZdeeddd d Zed d d Zeed ddZ eddddZ ee ed ddZ dS)rIz,Union[SpawnProcess, subprocess.Popen[bytes]])rLcCs||_|jdk stddS)Nzprocess not yet spawned)_ppidr\)selfrLrrr9__init__>szCombinedProcess.__init__rrN)r)r*r/cCstjdd|rtdt|jtj z| |Wn"t j k r`t d|YnX|jdkrt dt|jtj| |qtdnt d|jdS)NrNzstopping process...z!SIGINT timed out after %r secondsz+process has not terminated, sending SIGKILLzprocess stoppedz#process already dead, exit code: %d)rRrSpopis_aliver2r(killresignalSIGINTjoinr]TimeoutExpiredr[exitcodeSIGKILL)rfr)r*rrr9r5Bs      zCombinedProcess.stopr/cCs(t|jtr|jS|jdkSdSN)rTrdrripollrfrrr9riZs  zCombinedProcess.is_alivecCs|jjSrr)rdrertrrr9re`szCombinedProcess.pid)timeoutr/cCs*t|jtr|j|n |j|dSrr)rTrdrrmwait)rfrurrr9rmes zCombinedProcess.joincCs t|jtr|jjS|jjSdSrr)rTrdrro returncodertrrr9roks zCombinedProcess.exitcode)rr) __name__ __module__ __qualname__rgintr5boolripropertyrermr rorrrr9rI=s)rOtty_pathr r!r/c Cs*t|t|}|||W5QRXdSrr)set_ttyr)rOr~r r!funcrrr9rWss rW) dotted_pathr/c Csz|ddd\}}Wn4tk rN}ztd|d|W5d}~XYnXt|}z t||WStk r}ztd|d|d |W5d}~XYnXdS) z Stolen approximately from django. Import a dotted module path and return the attribute/class designated by the last name in the path. Raise ImportError if the import fails.  .r"z!" doesn't look like a module pathNzModule "z" does not define a "z " attribute)striprsplit ValueError ImportErrorrgetattrAttributeError)r module_path class_nameemodulerrr9rys$ rrqcCsBzttjWStk r(YdStk r<YdSXdS)zr Return the path to the current TTY, if any. Virtually impossible to test in pytest, hence no cover. z/dev/ttyN)rRttynamesysstdinfilenoOSErrorrrrrr9rVs rV)NNN)r~r/c csP|rFz$t|}|t_dVW5QRXWqLtk rBdVYqLXndVdSrr)openrrr)r~ttyrrr9rs r)signum_framer/cCstdt|tdS)Nz-received signal %s, raising KeyboardInterrupt)r2r[rkSignalsKeyboardInterrupt)rrrrr9raise_keyboard_interruptsrcCs"tdtttjtdS)a Catch SIGTERM and raise KeyboardInterrupt instead. This means watchfiles will stop quickly on `docker compose stop` and other cases where SIGTERM is sent. Without this the watchfiles process will be killed while a running process will continue uninterrupted. z8registering handler for SIGTERM on watchfiles process %dN)r2r(rRgetpidrkSIGTERMrrrrr9r3sr3)N)< contextlibrPloggingrRrbrFrkr]r importlibrmultiprocessingrZmultiprocessing.contextrpathlibrtimertypingrrr r r r r rrrr;filtersrmainrrrrr__all__ getLoggerr2rUr|floatr{rrrXrHr4rrIrWrrVcontextmanagerrrr3rrrr9s     0         R    $ 6*