JTh2<SSKrSSKrSSKrSSKrSSKrSSKrSSKrSSKrSSKrSSK r SSK J r J r SSK Jr SSKJr Sr\R$"\5r/SQr"SS \5r"S S \5r"S S \5rSr"SS5r"SS\5rSSjrSSjrg)N) as_completedThreadPoolExecutor)Optional)_prctl_pr_set_pdeathsigTORCH_MP_PARALLEL_START)ProcessContextProcessExceptionProcessExitedExceptionProcessRaisedExceptionspawn SpawnContextstart_processescF^\rSrSrSS/rS\S\S\4U4SjjrSrSr U=r $) r ! error_index error_pidmsgpidcH>[TU]U5 XlX lX0lgN)super__init__rrr)selfrrr __class__s S/var/www/auris/envauris/lib/python3.13/site-packages/torch/multiprocessing/spawn.pyrProcessException.__init__$s  &c^[U5URURUR44$r)typerrrrs r __reduce__ProcessException.__reduce__*s&DzDHHd&6&6AAAr)rrr) __name__ __module__ __qualname____firstlineno__ __slots__strintrr"__static_attributes__ __classcell__rs@rr r !s3 ,ICc BBrr c<^\rSrSrSrS\S\S\4U4SjjrSrU=r $)r .zNException raised when a process failed due to an exception raised by the code.rrrc&>[TU]XU5 gr)rr)rrrrrs rrProcessRaisedException.__init__1s 95r) r$r%r&r'__doc__r)r*rr+r,r-s@rr r .s,X6 66 66rr c \^\rSrSrSrS/rS S\S\S\S\S\\4 U4Sjjjr S r S r U=r $) r :zTException raised when a process failed due to signal or exited with a specific code. exit_coderrr signal_namec>>[TU]XU5 X@lXPlgr)rrr6r7)rrrrr6r7rs rrProcessExitedException.__init__?s 95"&rc[U5URURURURUR 44$r)r rrrr6r7r!s rr"!ProcessExitedException.__reduce__Ks9 J XXt''4>>4CSCS T  r)r6r7r) r$r%r&r'r3r(r)r*rrr"r+r,r-s@rr r :sZ^ I&* '  ' ' '  ' c] ' '  rr cL[[R5 U"U/UQ76 g![a g[ai SSKn[ US5n[R"UR5U5 SSS5 O!,(df  O=f[R"S5 gf=f)Nrwbr) rsignalSIGINTKeyboardInterrupt Exception tracebackopenpickledump format_excsysexit)fniargs error_filerBfhs r_wraprNRsw FMM*  1 t    *d #r KK ,,. 3$ # #  s, % B#B# &A90 B#9 B B#"B#cR\rSrSrSrSrS\4SjrS S\\S\\4Sjjr S r g) r fcX lXl[U5VVs0sHup4URU_M snnUlgs snnfr) error_files processes enumeratesentinel sentinels)rrSrRindexprocesss rrProcessContext.__init__gs@&":CI:N :NG  e #:N  s>clURVs/sHn[UR5PM sn$s snfr)rSr*r)rrXs rpidsProcessContext.pidsns'04?WGKK ???s1timeoutc[R"5U-nURH6n[SU[R"5- 5nUR U5 M8 g)z4Attempt to join all processes with a shared timeout.rN)time monotonicrSmaxjoin)rr]endrX time_to_waits r_join_procs_with_timeout'ProcessContext._join_procs_with_timeoutqsEnn(~~Gq#(8"89L LL &&rN grace_periodc[UR5S:Xag[RR URR 5US9nSnUHQnURR U5nURUnUR5 URS:wdMOUn O Uc[UR5S:H$UbURU5 URHJnUR5(dM[RSUR5 UR5 ML URUcSOU5 URHXnUR5(a0[RSUR5 UR!5 UR5 MZ URUn["R$"UR&U["R(5(d}URURn U S:a@[*R,"U *5R.n [3S US S U 3UURU U S 9e[3S US SU S 3UURU S9e[5UR&US5n [6R8"U 5n SSS5 SUS S3n U W - n [;XUR5e![0a SU *S 3n Nf=f!,(df  NG=f)aJoin one or more processes within spawn context. Attempt to join one or more processes in this spawn context. If one of them exited with a non-zero exit status, this function kills the remaining processes (optionally with a grace period) and raises an exception with the cause of the first process exiting. Returns ``True`` if all processes have been joined successfully, ``False`` if there are more processes that need to be joined. Args: timeout (float): Wait this long (in seconds) before giving up on waiting. grace_period (float): When any processes fail, wait this long (in seconds) for others to shutdown gracefully before terminating them. If they still don't exit, wait another grace period before killing them. rT)r]Nz)Terminating process %s via signal SIGTERMzJUnable to shutdown process %s via SIGTERM , forcefully exiting via SIGKILLzzprocess dz terminated with signal )rrr6r7z terminated with exit code )rrr6rbz -- Process z& terminated with the following error: )lenrVmultiprocessing connectionwaitkeyspoprSrbexitcodereis_alivelogwarningr terminatekillosaccessrRR_OKr>Signalsname ValueErrorr rCrDloadr )rr]rgreadyrrUrWrXfailed_processrsr}rMoriginal_tracers rrbProcessContext.joinxs( t~~ ! # **// NN   !0   HNN&&x0EnnU+G LLN1$#    t~~&!+ +  #  ) ), 7~~G!! GU!!#& %%L,@blS~~G!! `KK  LLN& 4yy))+6@@~~k2;;H!|;!>>8)499D-{1o-EdVL +,00& $ -{1o-HRS U +,00& $"";/ 6"#[[_N7 A.UV ~$S~7I7IJJ+";-xi[:D;"7 6s!K K%K"!K"% K3)rRrSrV)NN) r$r%r&r'rr[floatrerrbr+r2rrr r fsJ @''PT_K_K=Ee__K_Krr c(^\rSrSrU4SjrSrU=r$)rcP>[R"S5 [TU] X5 g)Nz[R"SSSS9nUR5 [R"UR 5 TR [TUTUR 4TS9nUR5 XUR 4$)Nzpytorch-errorfile-z.pickleF)prefixsuffixdelete)targetrKdaemon) tempfileNamedTemporaryFilecloseryunlinkr}ProcessrNstart)rJtfrXrKrrImps r start_process&start_processes..start_processsz ( (' %    "''**arww'   277""r) max_workers)ryenvirongetENV_VAR_PARALLEL_STARTruinforn get_contextrangersubmitrresultr rb)rIrKnprocsrbr start_methodstart_parallelrRrSrrJidxrXtf_nameexecutorfuturesfutcontextrs`` ` @rrrs=  $ JJNN13 73 > 23  $ $\ 2B&6/KI##( vA$1!$4 !C'& $cN  F 3xBG-P-Q}8-GP#G,(+ %g#*C !(# -4Y4G llnn llnnQ4 3s.E<E/EE E#c fUS:wa SUS3n[R"U[SS9 [XX#USS9$)aRSpawns ``nprocs`` processes that run ``fn`` with ``args``. If one of the processes exits with a non-zero exit status, the remaining processes are killed and an exception is raised with the cause of termination. In the case an exception was caught in the child process, it is forwarded and its traceback is included in the exception raised in the parent process. Args: fn (function): Function is called as the entrypoint of the spawned process. This function must be defined at the top level of a module so it can be pickled and spawned. This is a requirement imposed by multiprocessing. The function is called as ``fn(i, *args)``, where ``i`` is the process index and ``args`` is the passed through tuple of arguments. args (tuple): Arguments passed to ``fn``. nprocs (int): Number of processes to spawn. join (bool): Perform a blocking join on all processes. daemon (bool): The spawned processes' daemon flag. If set to True, daemonic processes will be created. start_method (str): (deprecated) this method will always use ``spawn`` as the start method. To use a different start method use ``start_processes()``. Returns: None if ``join`` is ``True``, :class:`~ProcessContext` if ``join`` is ``False`` r z3This method only supports start_method=spawn (got: zU). To use a different start_method use: torch.multiprocessing.start_processes(...)) stacklevel)r)rr FutureWarningr)rIrKrrbrrrs rr r ,sGBwA,P: :  c=Q7 2V6 PPr)r2rTFr )loggingrnmultiprocessing.connectionryrDr>rGrr_rconcurrent.futuresrrtypingrrr getLoggerr$ru__all__rAr r r rNr rrr r2rrrs!  ?%3 !  By B 6- 6 - 0(qKqKh1>1  A H(Qr