Vh dZddlmZddlZddlZddlZddlZddl m Z m Z ee dZ GddZ d d ej efd ZdS) z) Start multiple process locally for DDP. )partialN) simple_logfatalz Executor:c&eZdZdZdZdZdZdS)ChildrenManagerc"g|_d|_dS)NF)childrenfailedselfs S/var/www/html/movieo_spanner_bot/venv/lib/python3.11/site-packages/dora/executor.py__init__zChildrenManager.__init__s  clt|j|_|j|dSN)lenr rankappend)r childs raddzChildrenManager.adds/''  U#####rc|Srr s r __enter__zChildrenManager.__enter__s rc*|td|d|_ |jr|jst|jD]h} |d}|j||rtd|jdd|_T#tj$rYewxYw|jr|jn&#t$rtdd|_YnwxYw|jD]}| |jstddSdS)Nz-An exception happened while starting workers Tg?zWorker z died, killing all workersz8Received keyboard interrupt, trying to kill all workers.z"All workers completed successfully) logr r listwaitremoverspTimeoutExpiredKeyboardInterrupt terminate)r exc_type exc_value tracebackrexitcodes r__exit__zChildrenManager.__exit__"sr  K KK L L LDK - / /!$-00 / /E/#(::d#3#3 ,,U333#/ P%* P P PQQQ*.DK ,!!! ! - / /!    J K K KDKKK ]  E OO    { 6 4 5 5 5 5 5 6 6s5$B7B>GGr)__doc__ functoolsrrH subprocessr r>typingtprrrrOptionalrRr[rrrrbs   """"""""gj+&&"6"6"6"6"6"6"6"6J""r{3/?""""""r