U e5dï¿½ï¿½ï¿½@srdZddlZddlZddlZddlZddlZddlZddlZddl Z ddl mZddl mZddl m Z ddl mZddl mZdd lmZeï¿½dï¿½jZdAd dï¿½ZdBdd ï¿½ZdCddï¿½Zddï¿½ZGddï¿½dejï¿½ZeZzddlZWnek rï¿½YnXejZZddï¿½ddï¿½ZejjZejj Z ejj!Z!dde!dï¿½ddï¿½Z"ddï¿½Z#ddï¿½ddï¿½Z$dd ï¿½Z%d!d"ï¿½Z&ddd#ï¿½d$d%ï¿½Z'ej(d&d'ï¿½ï¿½Z)dDddï¿½d(d)ï¿½Z*ddï¿½d*d+ï¿½Z+ej(d,d-ï¿½ï¿½Z,ee,_Gd.d/ï¿½d/ej-ï¿½Z.dd0d1ï¿½d2d3ï¿½Z/ddï¿½d4d5ï¿½Z0d6d7ï¿½Z1e ï¿½2ï¿½Z3iZ4d8d9ï¿½Z5d:d;ï¿½Z6dd?ï¿½Z8e5Z9e8Z:e6Z;e7Ze6Z?e7Z@dS)E)ï¿½Taskï¿½create_taskï¿½FIRST_COMPLETEDï¿½FIRST_EXCEPTIONï¿½ ALL_COMPLETEDï¿½waitï¿½wait_forï¿½as_completedï¿½sleepï¿½gatherï¿½shieldï¿½ ensure_futureï¿½run_coroutine_threadsafeï¿½current_taskï¿½ all_tasksï¿½_register_taskï¿½_unregister_taskï¿½_enter_taskï¿½_leave_taskï¿½Nï¿½)ï¿½ base_tasks)ï¿½ coroutines)ï¿½events)ï¿½ exceptions)ï¿½futures)ï¿½ _is_coroutinecCs|dkrtï¿½ï¿½}tï¿½|ï¿½Sï¿½N)rï¿½get_running_loopï¿½_current_tasksï¿½getï¿½ï¿½loopï¿½r"ï¿½%/usr/lib64/python3.8/asyncio/tasks.pyr"srcs^ï¿½dkrtï¿½ï¿½ï¿½d}zttï¿½}WqLtk rF|d7}|dkrBï¿½YqXqLqï¿½fddï¿½|Dï¿½S)Nrrï¿½ï¿½cs&h|]}tï¿½|ï¿½ï¿½kr|ï¿½ï¿½s|ï¿½qSr")rï¿½ _get_loopï¿½doneï¿½ï¿½.0ï¿½tr r"r#ï¿½ <sï¿½zall_tasks..)rrï¿½listï¿½ _all_tasksï¿½RuntimeErrorï¿½r!ï¿½iZtasksr"r r#r)srcs^ï¿½dkrtï¿½ï¿½ï¿½d}zttï¿½}WqLtk rF|d7}|dkrBï¿½YqXqLqï¿½fddï¿½|Dï¿½S)Nrrr$csh|]}tï¿½|ï¿½ï¿½kr|ï¿½qSr")rr%r'r r"r#r*Usz$_all_tasks_compat..)rï¿½get_event_loopr+r,r-r.r"r r#ï¿½_all_tasks_compat@sr1cCs4|dk r0z |j}Wntk r&Yn X||ï¿½dSr)ï¿½set_nameï¿½AttributeError)ï¿½taskï¿½namer2r"r"r#ï¿½_set_task_nameXs r6csï¿½eZdZdZed$ddï¿½ï¿½Zed%ddï¿½ï¿½Zdddï¿½ï¿½fdd ï¿½ Zï¿½fd dï¿½Zdd ï¿½Z ddï¿½Z ddï¿½Zddï¿½Zddï¿½Z ddï¿½Zddï¿½ddï¿½Zdddï¿½ddï¿½Zddï¿½Zd&ï¿½fd d!ï¿½ Zd"d#ï¿½Zï¿½ZS)'rTNcCs(tjdtddï¿½|dkr tï¿½ï¿½}t|ï¿½S)NzVTask.current_task() is deprecated since Python 3.7, use asyncio.current_task() insteadï¿½ï¿½ï¿½ stacklevel)ï¿½warningsï¿½warnï¿½DeprecationWarningrr0rï¿½ï¿½clsr!r"r"r#rtsï¿½zTask.current_taskcCstjdtddï¿½t|ï¿½S)NzPTask.all_tasks() is deprecated since Python 3.7, use asyncio.all_tasks() insteadr7r8)r:r;r<r1r=r"r"r#rï¿½s ï¿½zTask.all_tasks)r!r5csï¿½tï¿½j|dï¿½|jr|jd=tï¿½|ï¿½s:d|_td|ï¿½ï¿½ï¿½ï¿½|dkrRdtï¿½ï¿½ï¿½|_n t |ï¿½|_d|_ d|_||_t ï¿½ï¿½|_|jj|j|jdï¿½t|ï¿½dS)Nr ï¿½ï¿½ï¿½ï¿½ï¿½Fza coroutine was expected, got zTask-ï¿½ï¿½context)ï¿½superï¿½__init__ï¿½_source_tracebackrï¿½iscoroutineï¿½_log_destroy_pendingï¿½ TypeErrorï¿½_task_name_counterï¿½_nameï¿½strï¿½_must_cancelï¿½_fut_waiterï¿½_coroï¿½contextvarsZcopy_contextï¿½_contextï¿½_loopï¿½ call_soonï¿½_Task__stepr)ï¿½selfï¿½coror!r5ï¿½ï¿½ __class__r"r#rCï¿½s z Task.__init__csF|jtjkr8|jr8|ddï¿½}|jr,|j|d<|jï¿½|ï¿½tï¿½ï¿½ï¿½dS)Nz%Task was destroyed but it is pending!)r4ï¿½messageZsource_traceback) Z_staterZ_PENDINGrFrDrPZcall_exception_handlerrBï¿½__del__)rSrArUr"r#rXï¿½sï¿½ zTask.__del__cCs tï¿½|ï¿½Sr)rZ_task_repr_infoï¿½rSr"r"r#ï¿½ _repr_infoï¿½szTask._repr_infocCs|jSr)rMrYr"r"r#ï¿½get_coroï¿½sz Task.get_corocCs|jSr)rIrYr"r"r#ï¿½get_nameï¿½sz Task.get_namecCst|ï¿½|_dSr)rJrI)rSï¿½valuer"r"r#r2ï¿½sz Task.set_namecCstdï¿½ï¿½dS)Nz*Task does not support set_result operationï¿½r-)rSï¿½resultr"r"r#ï¿½ set_resultï¿½szTask.set_resultcCstdï¿½ï¿½dS)Nz-Task does not support set_exception operationr^)rSï¿½ exceptionr"r"r#ï¿½ set_exceptionï¿½szTask.set_exception)ï¿½limitcCstï¿½||ï¿½Sr)rZ_task_get_stack)rSrcr"r"r#ï¿½ get_stackï¿½szTask.get_stack)rcï¿½filecCstï¿½|||ï¿½Sr)rZ_task_print_stack)rSrcrer"r"r#ï¿½print_stackï¿½s zTask.print_stackcCs4d|_|ï¿½ï¿½rdS|jdk r*|jï¿½ï¿½r*dSd|_dSï¿½NFT)Z_log_tracebackr&rLï¿½cancelrKrYr"r"r#rhï¿½s zTask.cancelc sï¿½|ï¿½ï¿½rtï¿½d|ï¿½d|ï¿½ï¿½ï¿½ï¿½|jr>t|tjï¿½s8tï¿½ï¿½}d|_|j}d|_t|j |ï¿½ï¿½zfz"|dkrp|ï¿½dï¿½}n |ï¿½|ï¿½}Wnï¿½t k rï¿½}z*|jrï¿½d|_tï¿½ï¿½ï¿½ntï¿½ï¿½|jï¿½W5d}~XYï¿½nï¿½tjk rï¿½tï¿½ï¿½ï¿½Yï¿½nï¿½ttfk ï¿½r}ztï¿½ï¿½|ï¿½ï¿½W5d}~XYï¿½nï¿½tk ï¿½rL}ztï¿½ï¿½|ï¿½W5d}~XYï¿½npXt|ddï¿½}|dk ï¿½r@tï¿½|ï¿½|j k ï¿½rï¿½td|ï¿½d|ï¿½dï¿½ï¿½}|j j|j||jdï¿½nï¿½|ï¿½r||kï¿½rï¿½td |ï¿½ï¿½ï¿½}|j j|j||jdï¿½n8d|_|j|j|jdï¿½||_|jï¿½r>|jï¿½ï¿½ï¿½r>d|_n*td |ï¿½d|ï¿½ï¿½ï¿½}|j j|j||jdï¿½n||dkï¿½r`|j j|j|jdï¿½n\t ï¿½!|ï¿½ï¿½rï¿½td|ï¿½d|ï¿½ï¿½ï¿½}|j j|j||jdï¿½n$td |ï¿½ï¿½ï¿½}|j j|j||jdï¿½W5t |j |ï¿½d}XdS)Nz_step(): already done: z, Fï¿½_asyncio_future_blockingzTask z got Future z attached to a different loopr@zTask cannot await on itself: z-yield was used instead of yield from in task z with z;yield was used instead of yield from for generator in task zTask got bad yield: )"r&rZInvalidStateErrorrKï¿½ isinstanceï¿½CancelledErrorrMrLrrPrï¿½sendï¿½throwï¿½ StopIterationrBrhr`r]ï¿½KeyboardInterruptï¿½ SystemExitrbï¿½ BaseExceptionï¿½getattrrr%r-rQrRrOriï¿½add_done_callbackï¿½ _Task__wakeupï¿½inspectZisgenerator)rSï¿½excrTr_Zblockingï¿½new_excrUr"r#Z__stepsï¿½ï¿½ ï¿½ï¿½ ï¿½ï¿½ï¿½ï¿½ï¿½ ï¿½ï¿½ï¿½ zTask.__stepc CsJz|ï¿½ï¿½Wn,tk r8}z|ï¿½|ï¿½W5d}~XYn X|ï¿½ï¿½d}dSr)r_rqrR)rSï¿½futurervr"r"r#Z__wakeup[sz Task.__wakeup)N)N)N)ï¿½__name__ï¿½ __module__ï¿½__qualname__rFï¿½classmethodrrrCrXrZr[r\r2r`rbrdrfrhrRrtï¿½ __classcell__r"r"rUr#rbs$!Tr)r5cCs tï¿½ï¿½}|ï¿½|ï¿½}t||ï¿½|Sr)rrrr6)rTr5r!r4r"r"r#rxs r)r!ï¿½timeoutï¿½return_whencï¿½sï¿½tï¿½|ï¿½stï¿½|ï¿½r(tdt|ï¿½jï¿½ï¿½ï¿½ï¿½|s4tdï¿½ï¿½|tt t fkrPtd|ï¿½ï¿½ï¿½ï¿½ï¿½dkrbtï¿½ï¿½ï¿½nt jdtddï¿½ï¿½fddï¿½t|ï¿½Dï¿½}t|||ï¿½ï¿½IdHS) Nzexpect a list of futures, not z#Set of coroutines/Futures is empty.zInvalid return_when value: ï¿½[The loop argument is deprecated since Python 3.8, and scheduled for removal in Python 3.10.r7r8csh|]}t|ï¿½dï¿½ï¿½qSï¿½r ï¿½rï¿½r(ï¿½fr r"r#r*ï¿½szwait..)rï¿½isfuturerrErGï¿½typeryï¿½ ValueErrorrrrrrr:r;r<ï¿½setï¿½_wait)ï¿½fsr!r~rr"r r#rï¿½s ï¿½rcGs|ï¿½ï¿½s|ï¿½dï¿½dSr)r&r`)ï¿½waiterï¿½argsr"r"r#ï¿½_release_waiterï¿½srï¿½r c ï¿½sï¿½|dkrtï¿½ï¿½}ntjdtddï¿½|dkr4|IdHS|dkrï¿½t||dï¿½}|ï¿½ï¿½rX|ï¿½ï¿½St||dï¿½IdHz|ï¿½ï¿½Wn.t j k rï¿½}zt ï¿½ï¿½|ï¿½W5d}~XYn Xt ï¿½ï¿½ï¿½|ï¿½ï¿½}|ï¿½ |t|ï¿½}tï¿½t|ï¿½}t||dï¿½}|ï¿½|ï¿½zï¿½z|IdHWnPt j k ï¿½rF|ï¿½ï¿½ï¿½r$|ï¿½ï¿½YWï¿½dS|ï¿½|ï¿½t||dï¿½IdHï¿½YnX|ï¿½ï¿½ï¿½r^|ï¿½ï¿½Wï¿½*S|ï¿½|ï¿½t||dï¿½IdHt ï¿½ï¿½ï¿½W5|ï¿½ï¿½XdS)Nrï¿½r7r8rr )rrr:r;r<rr&r_ï¿½_cancel_and_waitrrkï¿½TimeoutErrorï¿½ create_futureï¿½ call_laterrï¿½ï¿½ functoolsï¿½partialrsrhï¿½remove_done_callback)ï¿½futr~r!rvrï¿½ï¿½timeout_handleï¿½cbr"r"r#rï¿½sL ï¿½ rc ï¿½sï¿½|ï¿½ï¿½ï¿½dï¿½|dk r"|ï¿½|tï¿½ï¿½ï¿½t|ï¿½ï¿½ï¿½ï¿½ï¿½ï¿½fddï¿½}|D]}|ï¿½|ï¿½q@zï¿½IdHW5ï¿½dk rpï¿½ï¿½ï¿½|D]}|ï¿½|ï¿½qtXtï¿½tï¿½}}|D]"}|ï¿½ï¿½rï¿½|ï¿½ |ï¿½qï¿½|ï¿½ |ï¿½qï¿½||fS)NcsZï¿½d8ï¿½ï¿½dks4ï¿½tks4ï¿½tkrV|ï¿½ï¿½sV|ï¿½ï¿½dk rVï¿½dk rDï¿½ï¿½ï¿½ï¿½ï¿½ï¿½sVï¿½ï¿½dï¿½dS)Nrr)rrï¿½ cancelledrarhr&r`ï¿½rï¿½ï¿½Zcounterrrï¿½rï¿½r"r#ï¿½_on_completionsï¿½ï¿½ï¿½ ï¿½z_wait.._on_completion) rï¿½rï¿½rï¿½ï¿½lenrsrhrï¿½rï¿½r&ï¿½add)rï¿½r~rr!rï¿½rï¿½r&Zpendingr"rï¿½r#rï¿½ï¿½s(rï¿½c ï¿½sF|ï¿½ï¿½}tï¿½t|ï¿½}|ï¿½|ï¿½z|ï¿½ï¿½|IdHW5|ï¿½|ï¿½XdSr)rï¿½rï¿½rï¿½rï¿½rsrï¿½rh)rï¿½r!rï¿½rï¿½r"r"r#rï¿½&s rï¿½)r!r~c#sï¿½tï¿½|ï¿½stï¿½|ï¿½r(tdt|ï¿½jï¿½ï¿½ï¿½ï¿½ddlm}|ï¿½dï¿½ï¿½ï¿½dkrPt ï¿½ ï¿½ï¿½ntjdt ddï¿½ï¿½fdd ï¿½t|ï¿½Dï¿½ï¿½dï¿½ï¿½ï¿½ï¿½fd dï¿½}ï¿½ï¿½ï¿½fdd ï¿½ï¿½ï¿½fddï¿½}ï¿½D]}|ï¿½ï¿½ï¿½qï¿½ï¿½rï¿½|dk rÒˆï¿½||ï¿½ï¿½ttï¿½ï¿½ï¿½D]}|ï¿½Vqï¿½dS)Nz#expect an iterable of futures, not r)ï¿½Queuer rï¿½r7r8csh|]}t|ï¿½dï¿½ï¿½qSrï¿½rï¿½rï¿½r r"r#r*Uszas_completed..cs*ï¿½D]}|ï¿½ï¿½ï¿½ï¿½ï¿½dï¿½qï¿½ï¿½ï¿½dSr)rï¿½ï¿½ put_nowaitï¿½clearrï¿½)rï¿½r&ï¿½todor"r#ï¿½_on_timeoutXs z!as_completed.._on_timeoutcs4ï¿½sdSï¿½ï¿½|ï¿½ï¿½ï¿½|ï¿½ï¿½s0ï¿½dk r0ï¿½ï¿½ï¿½dSr)ï¿½removerï¿½rhrï¿½)r&rï¿½rï¿½r"r#rï¿½^s z$as_completed.._on_completioncï¿½s$ï¿½ï¿½ï¿½IdH}|dkrtjï¿½|ï¿½ï¿½Sr)rrrï¿½r_rï¿½)r&r"r#ï¿½ _wait_for_onefsz#as_completed.._wait_for_one)rrï¿½rrErGrï¿½ryZqueuesrï¿½rr0r:r;r<rï¿½rsrï¿½ï¿½rangerï¿½)rï¿½r!r~rï¿½rï¿½rï¿½rï¿½ï¿½_r")rï¿½r&r!rï¿½rï¿½r#r7s* ï¿½rccs dVdSrr"r"r"r"r#ï¿½__sleep0us rï¿½cï¿½sr|dkrtï¿½IdH|S|dkr*tï¿½ï¿½}ntjdtddï¿½|ï¿½ï¿½}|ï¿½|tj ||ï¿½}z|IdHWï¿½S|ï¿½ ï¿½XdS)Nrrï¿½r7r8)rï¿½rrr:r;r<rï¿½rï¿½rZ_set_result_unless_cancelledrh)Zdelayr_r!rxï¿½hr"r"r#r ï¿½s$ ï¿½ï¿½r cCsï¿½tï¿½|ï¿½r6|dkrtï¿½ï¿½}|ï¿½|ï¿½}|jr2|jd=|Stï¿½|ï¿½rb|dk r^|tï¿½|ï¿½k r^t dï¿½ï¿½|St ï¿½|ï¿½r|tt |ï¿½|dï¿½Stdï¿½ï¿½dS)Nr?zRThe future belongs to a different loop than the one specified as the loop argumentr z:An asyncio.Future, a coroutine or an awaitable is required)rrErr0rrDrrï¿½r%rï¿½ruZisawaitablerï¿½_wrap_awaitablerG)Zcoro_or_futurer!r4r"r"r#rï¿½s rccs|ï¿½ï¿½EdHSr)ï¿½ __await__)Z awaitabler"r"r#rï¿½ï¿½srï¿½cs*eZdZddï¿½ï¿½fddï¿½ Zddï¿½Zï¿½ZS)ï¿½_GatheringFutureNr cstï¿½j|dï¿½||_d|_dS)Nr F)rBrCï¿½ _childrenï¿½_cancel_requested)rSï¿½childrenr!rUr"r#rCï¿½sz_GatheringFuture.__init__cCs6|ï¿½ï¿½rdSd}|jD]}|ï¿½ï¿½rd}q|r2d|_|Srg)r&rï¿½rhrï¿½)rSZretZchildr"r"r#rhï¿½s z_GatheringFuture.cancel)ryrzr{rCrhr}r"r"rUr#rï¿½ï¿½srï¿½F)r!ï¿½return_exceptionscsï¿½|s<|dkrtï¿½ï¿½}ntjdtddï¿½|ï¿½ï¿½ï¿½ï¿½ï¿½gï¿½ï¿½Sï¿½ï¿½ï¿½ï¿½ï¿½fddï¿½}i}gï¿½dï¿½dï¿½|D]f}||krï¿½t||dï¿½}|dkrï¿½tï¿½ |ï¿½}||k rï¿½d|_ ï¿½d 7ï¿½|||<|ï¿½|ï¿½n||}ï¿½ï¿½|ï¿½qdt ï¿½|dï¿½ï¿½ï¿½S) Nrï¿½r7r8csï¿½ï¿½d7ï¿½ï¿½ï¿½ï¿½r$|ï¿½ï¿½s |ï¿½ï¿½dSï¿½sd|ï¿½ï¿½rFtï¿½ï¿½}ï¿½ï¿½|ï¿½dS|ï¿½ï¿½}|dk rdï¿½ï¿½|ï¿½dSï¿½ï¿½krï¿½g}ï¿½D]8}|ï¿½ï¿½rï¿½tï¿½ï¿½}n|ï¿½ï¿½}|dkrï¿½|ï¿½ï¿½}|ï¿½|ï¿½qtï¿½jrÄˆï¿½tï¿½ï¿½ï¿½n ï¿½ï¿½ |ï¿½dS)Nr) r&rï¿½rarrkrbr_ï¿½appendrï¿½r`)rï¿½rvZresultsï¿½resï¿½rï¿½Z nfinishedZnfutsï¿½outerrï¿½r"r#ï¿½_done_callbacks4 zgather.._done_callbackrr Fr)rr0r:r;r<rï¿½r`rrr%rFrsrï¿½rï¿½)r!rï¿½Zcoros_or_futuresrï¿½Z arg_to_futï¿½argrï¿½r"rï¿½r#r ï¿½s: ï¿½ 1 r cst|dk rtjdtddï¿½t||dï¿½ï¿½ï¿½ï¿½ï¿½r0ï¿½Stï¿½ï¿½ï¿½}|ï¿½ï¿½ï¿½ï¿½fddï¿½ï¿½ï¿½ï¿½fddï¿½}ï¿½ï¿½ï¿½ï¿½ï¿½ï¿½|ï¿½ï¿½S) Nrï¿½r7r8r cs\ï¿½ï¿½ï¿½r|ï¿½ï¿½s|ï¿½ï¿½dS|ï¿½ï¿½r.ï¿½ï¿½ï¿½n*|ï¿½ï¿½}|dk rJï¿½ï¿½|ï¿½nï¿½ï¿½|ï¿½ï¿½ï¿½dSr)rï¿½rarhrbr`r_)ï¿½innerrvï¿½rï¿½r"r#ï¿½_inner_done_callbackus z$shield.._inner_done_callbackcsï¿½ï¿½ï¿½sï¿½ï¿½ï¿½ï¿½dSr)r&rï¿½rï¿½)rï¿½rï¿½r"r#ï¿½_outer_done_callbackï¿½sz$shield.._outer_done_callback) r:r;r<rr&rr%rï¿½rs)rï¿½r!rï¿½r")rï¿½rï¿½rï¿½r#rPsï¿½ rcs:tï¿½ï¿½ï¿½stdï¿½ï¿½tjï¿½ï¿½ï¿½ï¿½ï¿½ï¿½fddï¿½}ï¿½ï¿½|ï¿½ï¿½S)NzA coroutine object is requiredc slztï¿½tï¿½ï¿½dï¿½ï¿½ï¿½WnNttfk r2ï¿½Yn6tk rf}zï¿½ï¿½ï¿½rTï¿½ï¿½|ï¿½ï¿½W5d}~XYnXdS)Nr )rZ _chain_futurerrprorqZset_running_or_notify_cancelrb)rvï¿½rTrxr!r"r#ï¿½callbackï¿½s z*run_coroutine_threadsafe..callback)rrErGï¿½ concurrentrï¿½FutureZcall_soon_threadsafe)rTr!rï¿½r"rï¿½r#r ï¿½s r cCstï¿½|ï¿½dSr)r,rï¿½ï¿½r4r"r"r#rï¿½srcCs4tï¿½|ï¿½}|dk r(td|ï¿½d|ï¿½dï¿½ï¿½ï¿½|t|<dS)NzCannot enter into task z while another task z is being executed.ï¿½rrr-ï¿½r!r4rr"r"r#rï¿½s rcCs2tï¿½|ï¿½}||k r(td|ï¿½d|ï¿½dï¿½ï¿½ï¿½t|=dS)Nz Leaving task z! does not match the current task ï¿½.rï¿½rï¿½r"r"r#rï¿½s rcCstï¿½|ï¿½dSr)r,ï¿½discardrï¿½r"r"r#rï¿½sr)rrrrr,r)N)N)N)N)Aï¿½__all__Zconcurrent.futuresrï¿½rNrï¿½ruï¿½ itertoolsï¿½typesr:ï¿½weakrefï¿½rrrrrrï¿½countï¿½__next__rHrrr1r6Z _PyFuturerZ_PyTaskZ_asyncioï¿½ImportErrorZ_CTaskrrrrrrï¿½rrï¿½rï¿½rï¿½ coroutinerï¿½r rrï¿½rï¿½rï¿½r rr ZWeakSetr,rrrrrZ_py_register_taskZ_py_unregister_taskZ_py_enter_taskZ_py_leave_taskZ_c_register_taskZ_c_unregister_taskZ _c_enter_taskZ _c_leave_taskr"r"r"r#ï¿½sï¿½ #H,> x?$