a

5½ËhÕã@s@dd
lm
Z
mZmZ
ddlmZ
ddlmZ
dd„Zdd„Z	dS)	é)ÚThreadÚEventÚBoundedSemaphore©
Úwraps)
ÚRetryExceptionc
stˆƒ
‡f
d
d„ƒ
}
|
S)aÛ

        run_async(func)
            function decorator, intended to make "func" run in a separate
            thread (asynchronously).
            Returns the created Thread object

            E.g.:
            @run_async
            def task1():
                do_something

            @run_async
            def task2():
                do_something_too

            t1 = task1()
            t2 = task2()
            ...
            t1.join()
            t2.join()
    cstˆ||
d
}| 
¡
|S)N©ÚtargetÚargsÚkwargs)rÚstart)r
rÚfunc_hl©
Úfunc©ú7/usr/lib/python3.9/site-packages/contego/async_utils.pyÚ
async_func s

zrun_async.<locals>.async_funcr©rrrrrÚ	run_async	s
rc
s‡f
d
d„}
|
S)Nc
stˆƒ
‡‡
fd
d„ƒ
}
|
S)Ncs‚tƒ}‡
f
d
d„}ˆ
 
d¡
rvz4|
 |ˆdœ¡

t|||
d}| ¡
| ¡
|WStyr


ˆ
 ¡
tdƒ
‚
Yq~0ntdƒ
‚
dS)NcsF|
 d
¡
}|
 d¡
}| 
¡
z||i|
¤
Ž

Wˆ ¡
n
ˆ ¡
0dS)NÚthread_start_eventÚactual_func)ÚpopÚsetÚrelease)r
rZtheventZthfunc©
Ú
throttlingrrÚthread_wrapper_func/s






zYrun_async_by_throttle.<locals>.run_async.<locals>.async_func.<locals>.thread_wrapper_funcF)rrrz	Retry....)	rÚacquireÚupdaterrÚwaitÚ
BaseExceptionrr)r
rZeventrr
)rrrrr+s	




ÿ




z<run_async_by_throttle.<locals>.run_async.<locals>.async_funcrrrrrr*s

z(run_async_by_throttle.<locals>.run_asyncr)rrrrrÚrun_async_by_throttle)s
r!N)
Ú	threadingrrrÚ	functoolsrZcontego.exceptionrrr!rrrrÚ<module>s