U
|
Z ±dQB ã @ sð d dl Z d dlZd dlmZ d dlZd dlmZ e jdk rPd dlm Z m
|
Z
|
m Z n d dl m Z dd Z ejd d
|
G d d d ZG d d de ZG dd dee
|
Zde_de_z d dlZW n ek
|
rÐ dZY nX d Zerädd Zn*d dlZd dlZG dd dejZdd Zdd Zde j krpd dl Z e ¡ Z e dk rpe j dkrXej!d e"d nd'd d Z#e $e fe#¡ e jdk rìe%e j&d dd!krìd d"l'm(Z( d dl)Z)d d#lm*Z* e j&e)j+ksÂt,d$d% Z-e(d&Z.e.j/ 0e j/¡ e-e._1e.e)_ dS )(é N)ÚSequence)Úwarn_deprecated)é é )ÚBaseExceptionGroupÚExceptionGroupÚprint_exception©r c s> fdd fddt } ||}d || |S )Nc s t | trng }d}| jD ],} ||}||k r2d}|d k r| |¡ q|sNd S |rZt|S | t| ¡ | S n"| }|d k r|| k r| |_|S d S ©NFT)Ú
|
isinstanceÚ
|
MultiErrorÚ
|
exceptionsÚappendÚaddÚidÚ __context__)ÚexcÚ preservedZnew_exceptionsÚchangedÚ child_excZ new_child_excÚnew_exc)Ú filter_treeÚhandler© úMd:\z\workplace\vscode\pyvenv\venv\Lib\site-packages\trio/_core/_multierror.pyr N s&
|
|
|
z!_filter_impl.<locals>.filter_treec sP t ||krd S t| |j}t|trF|jD ]} ||| q,d |_n||_d S ©N)r Ú concat_tbÚ __traceback__r r r )Útbr r Únew_tbr )Ú push_tb_downr r r f s
|
|
z"_filter_impl.<locals>.push_tb_down)Úset)r Úroot_excr Z new_root_excr )r r r r Ú _filter_impl s ;
|
r# T)Úfrozenc @ s$ e Zd Ze ¡ Zdd Zdd ZdS )ÚMultiErrorCatcherc C s d S r r ©Úselfr r r Ú __enter__ s zMultiErrorCatcher.__enter__c C sh |d k rdt | j|}||kr dS |d kr,dS |j}z|W 5 t ¡ \}}}||ksVt||_~~~X d S r
|
)r# Ú_handlerr ÚsysÚexc_infoÚAssertionError)r' Úetyper r Z filtered_excZ old_contextÚ_Úvaluer r r Ú__exit__ s zMultiErrorCatcher.__exit__N)Ú__name__Ú
|
__module__Ú __qualname__ÚattrÚibr) r( r0 r r r r r% s r% c sh e Zd ZdZdd fdd
|
Zdd fdd
|
Zdd Zd
|
d Zd d Ze dd Z
|
e dd Z Z S )r a^ An exception that contains other exceptions; also known as an
|
"inception".
|
|
It's main use is to represent the situation when multiple child tasks all
|
raise errors "in parallel".
|
|
Args:
|
exceptions (list): The exceptions
|
|
Returns:
|
If ``len(exceptions) == 1``, returns that exception. This means that a
|
call to ``MultiError(...)`` is not guaranteed to return a
|
:exc:`MultiError` object!
|
|
Otherwise, returns a new :exc:`MultiError` object.
|
|
Raises:
|
TypeError: if any of the passed in objects are not instances of
|
:exc:`BaseException`.
|
|
T©Ú _collapsec s0 || _ |r t| dd d k r d S t d|¡ d S )Nr úmultiple tasks failed)ÚcollapseÚgetattrÚsuperÚ__init__)r' r r7 ©Ú __class__r r r< · s zMultiError.__init__c sl t |}|D ] }t|ts td|q |rBt|dkrB|d S tdd |D rXt} t | d|¡S d S )Nz"Expected an exception object, not é r c s s | ]}t |tV qd S r )r Ú Exception©Ú.0r r r r Ú <genexpr>Ó s z%MultiError.__new__.<locals>.<genexpr>r8 ) Úlistr Ú BaseExceptionÚ TypeErrorÚlenÚallÚNonBaseMultiErrorr; Ú__new__)Úclsr r7 r r= r r rJ Â s
|
zMultiError.__new__c C s d dd | jD ¡S )Nz, c s s | ]}t |V qd S r )ÚreprrA r r r rC Ù s z%MultiError.__str__.<locals>.<genexpr>)Újoinr r& r r r Ú__str__Ø s zMultiError.__str__c C s
|
d | ¡S )Nz<MultiError: {}>)Úformatr& r r r Ú__repr__Û s zMultiError.__repr__c C s t |dd}| j|_|S )NFr6 )r r9 )r' Z_MultiError__excsr r r r ÚderiveÞ s zMultiError.derivec C s t ddddd t||S )uL Apply the given ``handler`` to all the exceptions in ``root_exc``.
|
|
Args:
|
handler: A callable that takes an atomic (non-MultiError) exception
|
as input, and returns either a new exception object or None.
|
root_exc: An exception, often (though not necessarily) a
|
:exc:`MultiError`.
|
|
Returns:
|
A new exception object in which each component exception ``exc`` has
|
been replaced by the result of running ``handler(exc)`` â or, if
|
``handler`` returned None for all the inputs, returns None.
|
|
zMultiError.filter()ú0.22.0zBaseExceptionGroup.split()é£ ©ZinsteadÚissue)r r# )rK r r" r r r Úfilterå s üzMultiError.filterc C s t ddddd t|S )z®Return a context manager that catches and re-throws exceptions
|
after running :meth:`filter` on them.
|
|
Args:
|
handler: as for :meth:`filter`
|
|
úMultiError.catchrR z!except* or exceptiongroup.catch()rS rT )r r% )rK r r r r Úcatchý s ürW ) r1 r2 r3 Ú__doc__r< rJ rN rP rQ Ú classmethodrV rX Ú __classcell__r r r= r r s
|
r c @ s e Zd ZdS )rI N)r1 r2 r3 r r r r rI s rI ZtrioFc s fdd}t |t| | ¡S )Nc s$ | j dkr | jd dkr S | ¡ S )N)Ú__getattribute__Ú __getattr__r Útb_next)ÚopnameÚargsZdelegate)Z operation©r^ r r Ú
|
controller5 s
|
zcopy_tb.<locals>.controller)ÚtputilZ
|
make_proxyÚtype)Úbase_tbr^ rb r ra r Úcopy_tb4 s rf c @ sB e Zd Zdeje ¡ fdejfdejfdejfdejfgZ dS )Ú
|
CTracebackZ PyObject_HEADr^ Útb_frameÚtb_lastiÚ tb_linenoN)
|
r1 r2 r3 ÚctypesÚc_byteÚobjectÚ
|
__sizeof__Úc_void_pÚc_intÚ_fields_r r r r rg P s ûrg c
|
C sÄ zt W n( t k
|
r0 } z
|
|j}W 5 d }~X Y nX t t|¡}|jd ksNt|d k rjt |¡ t||_|j d k sxtt | j ¡ |j }t| j |_ t
|
|¡ | j |_ | j |_ z|W ¢S ~~X d S r ) Ú
|
ValueErrorr rg Ú from_addressr r^ r, Ú_ctypesÚ Py_INCREFrh Ú Py_DECREFri rj )re r^ r r Zc_new_tbZ old_tb_framer r r rf Y s&
|
|
|
c C sD g }| }|d k r"| |¡ |j}q|}t|D ]}t||d}q.|S )Nra )r r^ Úreversedrf )ÚheadÚtailZhead_tbsÚpointerZ current_headZhead_tbr r r r s
|
r ÚIPythonr z·IPython detected, but you already have a custom exception handler installed. I'll skip installing Trio's custom handler, but this means exception groups will not show full tracebacks.)Úcategoryc C s t | d S r r )r' r- r/ r Z tb_offsetr r r Útrio_show_traceback s r} r1 Úapport_excepthook)Ú
|
ModuleType)Úformat_exceptionc C s t j d t| ||¡¡ d S )NÚ )r* ÚstderrÚwriterM r )r- r/ r r r r Úreplacement_excepthook¾ s r Z trio_fake_sys)N)2r* ÚwarningsÚtypingr r4 Ztrio._deprecater Ú version_infoZexceptiongroupr r r Ú tracebackr# Úsr% r rI r2 rc Ú ImportErrorZ have_tproxyrf rk rt Ú Structurerg r Úmodulesr{ Z get_ipythonÚipZcustom_exceptionsÚwarnÚRuntimeWarningr} Zset_custom_excr: Ú
|
excepthookÚtypesr Zapport_python_hookr r~ r, r Zfake_sysÚ__dict__ÚupdateÚ__excepthook__r r r r Ú<module> sd
|
l
|
p
|
|
&
|
û
|
ÿþ
|
