XjbddlmZddlmZmZddlmZmZddlm Z ddl m Z edZ GddZ Gd d e Zy ) ) annotations)CallableSequence)Any ParamSpec)is_async_callable)run_in_threadpoolPceZdZddZddZy)BackgroundTaskcN||_||_||_t||_yN)funcargskwargsris_async)selfrrrs h/mnt/ssd/data/Dropbox/adrian/vault-secondbrain/venv/lib/python3.12/site-packages/starlette/background.py__init__zBackgroundTask.__init__ s#   )$/ cK|jr/|j|ji|jd{yt |jg|ji|jd{y7;7wr)rrrrr )rs r__call__zBackgroundTask.__call__s[ ==$))TYY6$++6 6 6#DIII IT[[I I I 7 Is!6A8A45A8.A6/A86A8NrzCallable[P, Any]rzP.argsrzP.kwargsreturnNonerr)__name__ __module__ __qualname__rrrrr r s 0 Jrr c&eZdZdddZddZddZy) BackgroundTasksNc8|rt||_yg|_yr)listtasks)rr%s rrzBackgroundTasks.__init__s$)T%[ r rcXt|g|i|}|jj|yr)r r%append)rrrrtasks radd_taskzBackgroundTasks.add_tasks(d4T4V4 $rcPK|jD]}|d{y7wr)r%)rr(s rrzBackgroundTasks.__call__"s%JJ D&LL  s &$&r)r%zSequence[BackgroundTask] | Nonerr)rrrrr)rr rrr"r"s2 rr"N) __future__rcollections.abcrrtypingrrstarlette._utilsrstarlette.concurrencyr r r r"r rrr0s5".!.3 cN J J n r