o Th"'@sddlmZddlmZddlmZddlmZmZm Z m Z m Z m Z m Z mZddlZddlZddlZddlZddlZzddlmZddlmZWney[ddlmZddlZYnwd Zd"d d Zejd rleedZej Z de!d e e e!e!ffddZ"ede!d edfddZ#de d e$fddZ%de d ee$effddZ&de'd e e!fddZ(Gdddej)Z*ed d!Z+dS)#) namedtuple)contextmanager) TracebackType)Any GeneratorListIOOptionalTupleTypeUnionN)Lexicon)yamlz-%(name)s.%(module)s.%(funcName)s: %(message)sreturncCstjtjtddS)N)levelformat)logging basicConfigDEBUG LOG_FORMATrr>/var/www/html/venv/lib/python3.10/site-packages/invoke/util.pyenable_loggingsr INVOKE_DEBUGinvokenamecCs|d}|dd|dfS)zk Return key tuple for use sorting dotted task names, via e.g. `sorted`. .. versionadded:: 1.0 .N)split)rpartsrrrtask_name_sort_key-s  r!where)NNNc cs8t}t|z dVWt|dSt|w)N)osgetcwdchdir)r"cwdrrrcd?s  r'streamc Cs,zt|tWSttjfyYdSw)aq Cleanly determine whether ``stream`` has a useful ``.fileno()``. .. note:: This function helps determine if a given file-like object can be used with various terminal-oriented modules and functions such as `select`, `termios`, and `tty`. For most of those, a fileno is all that is required; they'll function even if ``stream.isatty()`` is ``False``. :param stream: A file-like object. :returns: ``True`` if ``stream.fileno()`` returns an integer, ``False`` otherwise (this includes when ``stream`` lacks a ``fileno`` method). .. versionadded:: 1.0 F) isinstancefilenointAttributeErrorioUnsupportedOperationr(rrr has_filenoIs r0cCs6t|drt|jr|St|rt|SdS)a Cleanly determine whether ``stream`` is a TTY. Specifically, first try calling ``stream.isatty()``, and if that fails (e.g. due to lacking the method entirely) fallback to `os.isatty`. .. note:: Most of the time, we don't actually care about true TTY-ness, but merely whether the stream seems to have a fileno (per `has_fileno`). However, in some cases (notably the use of `pty.fork` to present a local pseudoterminal) we need to tell if a given stream has a valid fileno but *isn't* tied to an actual terminal. Thus, this function. :param stream: A file-like object. :returns: A boolean depending on the result of calling ``.isatty()`` and/or `os.isatty`. .. versionadded:: 1.0 isattyF)hasattrcallabler1r0r#r*r/rrrr1as r1objcCs4|j}|r|r|t|jkrdS|dS)zo Yield an object's first docstring line, or None if there was no docstring. .. versionadded:: 1.0 Nr)__doc__striptypelstrip splitlines)r4 docstringrrrhelplinesr;csjeZdZdZdeddffdd Zdfdd Zded fd d Ze de fd d Z de fddZ ZS)ExceptionHandlingThreadaJ Thread handler making it easier for parent to handle thread exceptions. Based in part on Fabric 1's ThreadHandler. See also Fabric GH issue #204. When used directly, can be used in place of a regular ``threading.Thread``. If subclassed, the subclass must do one of: - supply ``target`` to ``__init__`` - define ``_run()`` instead of ``run()`` This is because this thread's entire point is to wrap behavior around the thread's execution; subclasses could not redefine ``run()`` without breaking that functionality. .. versionadded:: 1.0 kwargsrNc s(tjdi|d|_||_d|_dS)z Create a new exception-handling thread instance. Takes all regular `threading.Thread` keyword arguments, via ``**kwargs`` for easier display of thread identity when raising captured exceptions. TNr)super__init__daemonr=exc_info)selfr= __class__rrr?s z ExceptionHandlingThread.__init__cszt|drt|jr|WdStWdStyBt|_d}d}d|jvr4|jdj }t | |jd|YdSw)N_runz-Encountered exception {!r} in thread for {!r}targetr ) r2r3rEr>run BaseExceptionsysrAr=__name__debugr)rBmsgrrCrrrGs    zExceptionHandlingThread.runExceptionWrappercCs"|jdurdSt|jg|jRS)aP If an exception occurred, return an `.ExceptionWrapper` around it. :returns: An `.ExceptionWrapper` managing the result of `sys.exc_info`, if an exception was raised during thread execution. If no exception occurred, returns ``None`` instead. .. versionadded:: 1.0 N)rArMr=rBrrr exceptions z!ExceptionHandlingThread.exceptioncCs| o |jduS)z Returns ``True`` if not alive and has a stored exception. Used to detect threads that have excepted & shut down. .. versionadded:: 1.0 N)is_aliverArNrrris_deads zExceptionHandlingThread.is_deadcCst|jdjS)NrF)strr=rJrNrrr__repr__sz ExceptionHandlingThread.__repr__rN)rJ __module__ __qualname__r5rr?rGr rOpropertyboolrQrRrS __classcell__rrrCrr<s& r<rMzkwargs type value tracebackrT), collectionsr contextlibrtypesrtypingrrrrr r r r r-rr# threadingrIvendor.lexiconrvendorr ImportErrorlexiconrrenvironget getLoggerlogrKrRr!r'rXr0r1objectr;Threadr<rMrrrrs@  (        !x