o tBh;@sddlZddlZddlZddlZddlZddlZddlZddlZzddlZWn e y1dZYnwej dkZ ddZ dddZ dd d Zd d Zd dZddZddZddZdS)Nwin32cCst}d|_dS)z0Put a ``_clean_exit`` flag on the current threadTN) threadingcurrent_thread _clean_exit)threadrz/var/www/html/riverr-enterprise-integrations-main/venv/lib/python3.10/site-packages/joblib/externals/loky/backend/utils.py_flag_current_thread_clean_exits r TcCs$|r tdur t|dSt|dSN)psutil _recursive_terminate_with_psutil#_recursive_terminate_without_psutil)process use_psutilrrrrecursive_terminates   rc Csxz t|jjdd}Wn tjyYdSw|dddD]}z|Wqtjy1Yqw||dS)NT) recursive)r Processpidchildren NoSuchProcesskill terminatejoin)rretriesrchildrrrr s  r c CsRzt|jWnty"}ztd|WYd}~nd}~ww|dS)z-Terminate a process and its descendants. zgFailed to kill subprocesses on this platform. Pleaseinstall psutil: https://github.com/giampaolo/psutilN)_recursive_terminaterOSErrorwarningswarnrr)rerrrr 1s  r c Cstjdkrgztjddddt|gddWdStjyf}zC|jdvr%|jd krMz t|t j Wn t yL}z |j t j krBWYd}~nd}~wwWYd}~dSWYd}~dSWYd}~dSd}~wwztjd d t|gdd}Wntjy}z|jd krd }nWYd}~nd}~ww|d dd}|D] }t|}t|qz t|t j WdSt y}z|j t j krÂWYd}~dSd}~ww)zERecursively kill the descendants of a process before killing it. rtaskkillz/Fz/Tz/PIDN)stderr)r$pgrepz-P r)sysplatform subprocess check_outputstrCalledProcessError returncodeosrsignalSIGTERMrerrnoESRCHdecodesplitintr)rr! children_pidscpidrrrr?s^            rcCsrd}ddt|D}t|dkr5|dkr5|d8}ddt|D}tdt|dkr5|dkst|S)zReturn a formated string with the exitcodes of terminated workers. If necessary, wait (up to .25s) for the system to correctly set the exitcode of one terminated worker. rcSg|] }|jdur|jqSr exitcode.0prrr  z3get_exitcodes_terminated_worker..rr$cSr;r r<r>rrrrArBg?)listvalueslentimesleep_format_exitcodes) processespatience exitcodesrrrget_exitcodes_terminated_workerws rLcCs dd|D}dd|dS)z@Format a list of exit code with names of the signals if possiblecSs$g|]}|durdt||qS)Nz{}({}))format_get_exitcode_name)r?r!rrrrAs z%_format_exitcodes..{z, })r)rK str_exitcodesrrrrHsrHcCstjdkrdS|dkrHz2ddl}tjdkr|| jWS|jD]\}}|dr:|ds:|| kr:|WSq"WdSt yGYdSw|dkrNdSdS) NrUNKNOWNr)rSIGSIG_r&EXIT) r*r+r2 version_infoSignalsname__dict__items startswith ValueError)r=r2vkrrrrNs(     rN)T)r)r1r*rFr4r2rrr,r ImportErrorr+WIN32r rr r rrLrHrNrrrrs,     8