Ug  dZddlZddlZddlZddlZddlZddlZddlZddl Z ej Z ej Z e j j ZejjZejZejjZejjZejjZejZdZ ddZdS)z Helper for testing. NcDtjdfd }|t_dS)z& Redirect all warnings to stdout. Nrct||tj||tjdS)N)ospathbasenamesysstdout)msgcatfnamelnofilelineshowwarning_origs M/var/www/surfInsights/venv3-11/lib/python3.11/site-packages/joblib/testing.py showwarningz'warnings_to_stdout..showwarning s4c27#3#3E#:#:D#*MMMMM)Nr)warningsr)rrs @rwarnings_to_stdoutrsB +NNNNNN'Hrc tjtjtj fd} fd} |Utj||}|tjd|z|}| \}} || } } jdkr+d j|| } t| |8tj ||s#td |||8tj || s#td || |*| | dSdS#|)| | wwxYw) aRuns a command in a subprocess with timeout in seconds. A SIGTERM is sent after `timeout` and if it does not terminate, a SIGKILL is sent after `2 * timeout`. Also checks returncode is zero, stdout if stdout_regex is set, and stderr if stderr_regex is set. )r stderrc^tjddS)z Attempt to terminate a leftover process spawned during test execution: ideally this should not be needed but can help avoid clogging the CI workers in case of deadlocks. Timeout running N)rwarn terminatecmdprocsrterminate_processz0check_subprocess_call..terminate_process4s4  .../// rc^tjddS)z Kill a leftover process spawned during test execution: ideally this should not be needed but can help avoid clogging the CI workers in case of deadlocks. rN)rrkillrsr kill_processz+check_subprocess_call..kill_process=s/  .../// rNrz/Non-zero return code: {}. Stdout: {} Stderr: {}z,Unexpected stdout: {!r} does not match: {!r}z,Unexpected stderr: {!r} does not match: {!r}) subprocessPopenPIPE threadingTimerstart communicatedecode returncodeformat ValueErrorresearchcancel) rtimeout stdout_regex stderr_regexr r#terminate_timer kill_timerr rmessagers ` @rcheck_subprocess_callr9's   C #-? 4 4 4D  'og7HIIO  ! ! # # #"WlCCJ      ))++&--// ?a  %vOVV 5 5 W%% %  $IlF33 %?FF &**++ +  $IlF33 %?FF &**++ +    " " $ $ $          7   " " $ $ $        s EF))-G)rNN)__doc__rros.pathrr0r%r(pytest_pytestraiseswarnsrunnerSkippedSkipTestmarkskipiffixture parametrizer3xfailparamrr9rrrJs      > !   .k% +   '''8<'+< < < < < < r