⚝
One Hat Cyber Team
⚝
Your IP:
216.73.216.144
Server IP:
157.245.143.252
Server:
Linux www 6.11.0-9-generic #9-Ubuntu SMP PREEMPT_DYNAMIC Mon Oct 14 13:19:59 UTC 2024 x86_64
Server Software:
nginx/1.26.0
PHP Version:
8.3.11
Buat File
|
Buat Folder
Eksekusi
Dir :
~
/
usr
/
lib
/
python3.12
/
asyncio
/
__pycache__
/
View File Name :
taskgroups.cpython-312.pyc
CRh+" @ d Z ddlmZ ddlmZ ddlmZ G d d Zy)) TaskGroup )events) exceptions)tasksc R e Zd ZdZd Zd Zd Zd ZddddZd e d e fd Z d Z d Z y)r a9 Asynchronous context manager for managing groups of tasks. Example use: async with asyncio.TaskGroup() as group: task1 = group.create_task(some_coroutine(...)) task2 = group.create_task(other_coroutine(...)) print("Both tasks have completed now.") All tasks are awaited when the context manager exits. Any exceptions other than `asyncio.CancelledError` raised within a task will cancel all remaining tasks and wait for them to exit. The exceptions are then combined and raised as an `ExceptionGroup`. c d| _ d| _ d| _ d | _ d | _ d| _ t | _ g | _ d | _ d | _ y )NF) _entered_exiting _aborting_loop _parent_task_parent_cancel_requestedset_tasks_errors _base_error_on_completed_futselfs )/usr/lib/python3.12/asyncio/taskgroups.py__init__zTaskGroup.__init__ sN (-%e !% c x dg}| j r'|j dt | j | j r'|j dt | j | j r|j d n | j r|j d dj | }d| dS ) N ztasks=zerrors= cancellingentered z <TaskGroup>)r appendlenr r r join)r infoinfo_strs r __repr__zTaskGroup.__repr__( s t ;; KK&T[[!1 23 4 << KK'#dll"3!45 6 >> KK % ]] KK "88D>H:Q''r c K | j rt d| d | j t j | _ t j | j | _ | j t d| d d| _ | S w)N TaskGroup z has already been enteredz! cannot determine the parent taskT)r RuntimeErrorr r get_running_loopr current_taskr r s r __aenter__zTaskGroup.__aenter__6 s == TH$=>@ @ :: 002DJ ! . .tzz : $ TH$EFH H s B B c K d| _ |$| j | r| j || _ |t j u r|nd }| j r | j j dk( rd }| | j s| j | j rT| j | j j | _ | j d { d | _ | j rT| j rJ | j | j |r| j s||-|t j ur| j j | | j r t! d| j }|d y 7 # t j $ r(}| j s|}| j Y d }~d }~ww xY w# d | _ w xY ww)NT z unhandled errors in a TaskGroup)r _is_base_errorr r CancelledErrorr r uncancelr _abortr r r create_futurer r BaseExceptionGroup)r etexctb propagate_cancellation_errorexmes r __aexit__zTaskGroup.__aexit__D s O##C( ( "D 222C % ( ( ))+q0 04, >>> kk%%-)-)A)A)C& ",,,, &*D "' kk* ;; '"" " ( . . >b (A(A A LL $ << $'(I4<<Xd" ; - ,, "~~ 460KKM "H $ sa CGE= E;E= G/A1G!F; :G;E= =F8 F3.G3F88G; GGN)namecontextc | j st d| d | j r| j st d| d | j rt d| d | | j j | }n | j j || }t j || |j r| j | |S | j j | |j | j |S )zbCreate a new task in this group and return it. Similar to `asyncio.create_task`. r& z has not been enteredz is finishedz is shutting down)r; ) r r' r r r r create_taskr _set_task_namedone _on_task_doneaddadd_done_callback)r coror: r; tasks r r= zTaskGroup.create_task s }} D83H IJ J == D8< @A A >> D83D EF F ?::))$/D::))$)@D T4( 99; t $ KKOOD ! " "4#5#5 6 r r4 returnc R t |t sJ t |t t f S )N) isinstance BaseException SystemExitKeyboardInterrupt)r r4 s r r- zTaskGroup._is_base_error s% #}---# ,= >??r c v d| _ | j D ]# }|j r|j % y )NT)r r r? cancel)r ts r r0 zTaskGroup._abort s) A668 r c | j j | | j A| j s5| j j s| j j d |j ry |j }|y | j j | | j | r| j || _ | j j r1| j j d|d| j d||d y | j s?| j s2| j! d| _ | j j# y y y )NTzTask z% has errored out but its parent task z is already completed)message exceptionrD )r discardr r? set_result cancelledrP r r r- r r r call_exception_handlerr r r0 rL )r rD r4 s r r@ zTaskGroup._on_task_done s3 D! ! ! -dkk))..0&&11$7 >> nn ; C s #(8(8(@ "D ! ! # JJ - - "4( +##'#4#4"55J L / ~~d&C&C& KKM,0D ) $ $ &+ 'D~r )__name__ __module__ __qualname____doc__r r$ r* r9 r= rH boolr- r0 r@ r r r r sI & ( O$b )-d <@- @D @2'r r N)__all__r r r r r rZ r r <module>r\ s! d' d'r