+ j@2Rt^RIt^RIt^RIHt^RIHt^RIHtH t H t H t H t H t HtHtHtHt^RIHtHt^RIHtHtHt^RIHt^RIHtHtHt^R IH t H!t!^R I"H#t#^R I$H%t%^R I&H't'^R I(H)t)^RI*H+t+^RI,H-t-^RI.H/t/H0t0^RI1H2t2^RI3H4t4^RI5H6t6H7t7^RI8H9t9H:t:^RI;Ht>H?t?H@t@HAtA^RIBHCtCHDtDHEtE!RR] ]!4tFRRltG]!RR44tH]!RR44tI]!R R!44tJR"R#ltKR$R%ltL]!R&R'44tMR#)(z This module contains the trial distributed runner, the management class responsible for coordinating all of trial's behavior at the highest level. @since: 12.3 N)partial)isabs) Any AwaitableCallableIterableListOptionalSequenceTextIOUnioncast)TestCase TestSuite)definefieldfrozen)default_if_none)Deferred DeferredList gatherResults) IReactorCoreIReactorProcess)Logger)Failure)FilePath)FilesystemLock) theSystemPath) _iterateTests) IReporter ITestCase)UncleanWarningsReporterWrapper) TestHolder)_unusedTestDirectory openTestLog)_WORKER_AMP_STDIN_WORKER_AMP_STDOUT DistReporter) countingCalls discardResult iterateWhile takeWhile) LocalWorkerLocalWorkerAMP WorkerActionc]tRt^3tRtRtR#)IDistTrialReactorz/ The reactor interfaces required by disttrial. N)__name__ __module__ __qualname____firstlineno____doc____static_attributes__r2?/usr/lib/python3/dist-packages/twisted/trial/_dist/disttrial.pyr1r13sr9r1c$V^8dQhR\/#return)r1)formats"r: __annotate__r@9sEE*Er9c^RIHuHp\\P !V4\ P !V4.4'd\\V4#\R4h)zJ Get the default reactor, ensuring it is suitable for use with disttrial. Nz-Reactor does not provide the right interfaces) twisted.internet.reactorinternetreactorallr providedByrr r1 TypeError)defaultReactors r:_defaultReactorrI9sT65  # #N 3  & &~ 6 %~66 C DDr9c0a]tRt^MtoRtV3RltRtVtR#)WorkerPoolConfigar Configuration parameters for a pool of test-running workers. @ivar numWorkers: The number of workers in the pool. @ivar workingDirectory: A directory in which working directories for each of the workers will be created. @ivar workerArguments: Extra arguments to pass the worker process in its argv. @ivar logFile: The basename of the overall test log file. cj<V^8dQh/S[;R&S[S[,;R&S[S[,;R&S[;R&#)r= numWorkersworkingDirectoryworkerArgumentslogFile)intrrr str)r? __classdict__s"r:r@WorkerPoolConfig.__annotate__Ms? O!"sm##$c]"%&L'r9r2N)r3r4r5r6r7__annotate_func__r8__classdictcell__rSs@r:rKrKMs r9rKcba]tRt^ctoRt]!4tV3RlRltV3RlRltV3Rlt Rt Vt R#) StartedWorkerPoola A pool of workers which have already been started. @ivar workingDirectory: A directory holding the working directories for each of the workers. @ivar testDirLock: An object representing the cooperative lock this pool holds on its working directory. @ivar testLog: The open overall test log file. @ivar workers: Objects corresponding to the worker child processes and adapting between process-related interfaces and C{IProtocol}. @ivar ampWorkers: AMP protocol instances corresponding to the worker child processes. c4<V^8dQhRS[S[,RR/#)r= workerActionr>N)r/r)r?rSs"r:r@StartedWorkerPool.__annotate__s l3&7Dr9c ba"\V3RlVP44GRjxL R#L5i)z2 Run an action on all of the workers in the pool. c3F<"TFp\S!V44xK R#5iN)r*).0workerr[s& r: (StartedWorkerPool.run..s! >MFM,v. / /os!N)r ampWorkers)selfr[s&fr:runStartedWorkerPool.runs5 >Boo     s #/-/c<V^8dQhRR/#)r=r>Nr2)r?rSs"r:r@r\s""D"r9c "\VPUu.uF'p\P!VP 44NK) upRR7GRjxL p\ V4F2wpwrEV'dKVP PRV R2V4K4 VPRVPRVPP4VPP4R#uupiL5i)z^ Shut down all of the workers in the pool. The pool is unusable after this method is called. T) consumeErrorsNzjoining disttrial worker #z failed:NNN) rworkersr fromCoroutineexit enumerate_loggerfailurerdtestLogclose testDirLockunlock)reraresultsn succeededrps& r:joinStartedWorkerPool.joins %AE NvX # #FKKM 2 N  (1'9 #A# 9 $$'A!G%LgV(: LLO OOA   ! O s#C,-C% C,C*C,1A:C,c<V^8dQh/S[S[,;R&S[;R&S[;R&S[S[,;R&S[S[,;R&#)r=rNrsrqrkrd)rrrr rr-r.)r?rSs"r:r@r\csS(sm#)* +,O-.+ /0^$$1r9r2N) r3r4r5r6r7rrorfrxrUr8rVrWs@r:rYrYcs/0hG""Kr9rYcZa]tRt^toRtV3RlRltRtV3RlRltV3RltRt Vt R #) WorkerPoolz Manage a fixed-size collection of child processes which can run tests. @ivar _config: Configuration for the precise way in which the pool is run. c b<V^8dQhRS[S[,RS[S[,RS[RS[S[,/#)r= protocolsrNrPr>)rr.rrr rr-)r?rSs"r:r@WorkerPool.__annotate__sA  N+ #3-   k   r9c  \V4UUu.uF)wrE\WRP\V44V4NK+ upp#uuppi)aL Create local worker protocol instances and return them. @param protocols: The process/protocol adapters to use for the created workers. @param workingDirectory: The base path in which we should run the workers. @param logFile: The test log, for workers to write to. @return: A list of C{quantity} C{LocalWorker} instances. )rnr-childrR)rer~rNrPxprotocols&&&& r:_createLocalWorkersWorkerPool._createLocalWorkerssF* )3 3  "8"8Q"@' J3   s/Ac  \R,PPp^R^R^R\R\R/p\ P P4p\ PP\P4VR&VF@p\PV.pVPV4V!V\PWVR7KB R#)z Spawn processes from a list of process protocols. @param spawner: A C{IReactorProcess.spawnProcess} implementation. @param protocols: An iterable of C{ProcessProtocol} instances. @param arguments: Extra arguments passed to the processes. ztwisted.trial._dist.workertrialwr PYTHONPATH)argschildFDsenvN) rfilePathpathr%r&osenvironcopypathseprxsys executableextend) respawnerr~ argumentsworkertrialPathrrrars &&&& r:_launchWorkerProcesses!WorkerPool._launchWorkerProcessess((IJSSXX s s s s   **//#!#  9 FNNO4D KK " FCNNg V r9c&<V^8dQhRS[RS[/#)r=rDr>)rrY)r?rSs"r:r@rs& & ?& 7H& r9c R"\VPP4wr#\VPP4'd!\ VPP4pM%VP VPP4p\V4p\VPP4Uu.uF p\4NK ppVPVVV4pVPVPVVPP4\VVVVV4#uupi5i)zo Launch all of the workers for this pool. @return: A started pool object that can run jobs using the workers. )r#_configrNrrPr preauthChildr$rangerMr.rr spawnProcessrOrY) rerDtestDirrs testLogPathrqrrdrks && r:startWorkerPool.starts 4 LL ) )  %% & &"4<<#7#78K "..t||/C/CDKk*05dll6M6M0NO0N1n&0N O**     ##   LL ( ( !        PsB8D':D" AD'c&<V^8dQh/S[;R&#)r=r)rK)r?rSs"r:r@rsr9r2N) r3r4r5r6r7rrrrUr8rVrWs@r:r|r|s,  0W6& & {r9r|c<V^8dQhR\R\R\/#)r= untilFailureresultr>)boolr)r?s"r:r@r@s! 3 3 3y 3T 3r9c6T;'dVP4#)z Determine whether the test suite should be iterated again. @param untilFailure: C{True} if the suite is supposed to run until failure. @param result: The test result of the test suite iteration which just completed. ) wasSuccessful)rrs&&r:shouldContinuers  2 2F0022r9c V^8dQhR\R\\,R\R\\\ \,\ .\R,3,RR/#)r=pool testCasesr driveWorkerNr>)rYrr r(rr r.r)r?s"r:r@r@scFF F "F F x *N;Yt_L F Fr9c"VP\W2V44GRjxL R#L \d2TPP \ R4\ 44R#i;i5i)Nz )rfr ExceptionoriginaladdErrorr"r)rrrrs&&&&r:runTestsrsQFhhw{I>??? F   L!979E Fs1A*+)+A*+8A'#A*&A''A*c*a]tRtRtoRt]t]!4tRt ] !R] !] R7R7t ] !R] !]P4R7tRtRtRtRtR t]tV3R lR ltR tV3R lRltRV3RlRlltV3RlRltV3RlRltV3RlRltV3RltRt Vt!R#)DistTrialRunneri!a A specialized runner for distributed trial. The runner launches a number of local worker processes which will run tests. @ivar _maxWorkers: the number of workers to be spawned. @ivar _exitFirst: ``True`` to stop the run as soon as a test case fails. ``False`` to run through the whole suite and report all of the results at the end. @ivar stream: stream which the reporter will use. @ivar _reporterFactory: the reporter class to be used. FN)factory)default converterrztest.log _trial_tempc <V^8dQhRS[/#r<r')r?rSs"r:r@DistTrialRunner.__annotate__Js 3 3\ 3r9c VPVPVPVPR7pVP'd \ V4pVP V4#)z< Make reporter factory, and wrap it with a L{DistReporter}. )realtime)_reporterFactorystream_tracebackFormat_realTimeErrors_uncleanWarningsr!_distReporterFactory)rereporters& r: _makeResultDistTrialRunner._makeResultJsY(( KK..9M9M)   5h?H((22r9c &VP4R#)zr Write test run final outcome to result. @param result: A C{TestResult} which will print errors and the summary. N)done)rers&&r: writeResultsDistTrialRunner.writeResultsUs  r9c@<V^8dQhRS[RS[S[,RS[RR/#)r=rrrar>N)r(r r r.)r?rSs"r:r@r]s8I&   r9c Vaa"VV3RlpVFpV!V4GRjxL K R#L 5i)aP Drive a L{LocalWorkerAMP} instance, iterating the tests and calling C{run} for every one of them. @param worker: The L{LocalWorkerAMP} to drive. @param result: The global L{DistReporter} instance. @param testCases: The global list of tests to iterate. @return: A coroutine that completes after all of the tests have completed. c<"SPVS4GRjxL R#L \d)SPPT\ 44R#i;i5ir_)rfrrrr)caserras&r:task*DistTrialRunner._driveWorker..taskqsC :jjv... :((wy9 :s1A#!#A#/AAAANr2)rerrrarrs&f&f r: _driveWorkerDistTrialRunner._driveWorker]s'( : Dt*   s )' )cB<V^8dQhRS[S[S[3,RS[RS[/#)r=suiterr>)r rrrr()r?rSs"r:r@rzs8J%J%Xy()J%J%  J%r9c aaaa"\\V44oSP\\ \ S4SP 4\SP4SPSP44pSPPRVP4 R24VPSP4GRjxL o\!\"S4p\$RVVVV3Rll4p\'WE4GRjxL SP)4GRjxL #LULL SP)4GRjxL i;i5i)z Spawn local worker processes and load tests. After that, run them. @param suite: A test or suite to be run. @param untilFailure: If C{True}, continue to run the tests until they fail. @return: A coroutine that completes with the test result. zRunning z tests. Nc0V^8dQhR\R\/#)r=rvr>)rQr()r?s"r:r@.DistTrialRunner.runAsync..__annotate__s  # , r9c@<a"S'd'SPPRV^, R24SP4oSP'dV3RlpMRp\ S\ VS4SSP 4GRjxL SPS4S#L5i)z Test Pass  c8<SPP4#r_)rr)_rs&r:@DistTrialRunner.runAsync..runAndReport..s6??+H+H+Jr9cR#)Tr2)rs&r:rrs4r9N)rwriter _exitFirstrr,rr)rvcasesConditionrre startedPoolrrs& @r: runAndReport.DistTrialRunner.runAsync..runAndReports !!Jq1ugR"89%%'F"K!/.)4!!      f %M sAB/BBB)listr_workerPoolFactoryrKminlen _maxWorkersr_workingDirectory_workerArguments_logfilerrcountTestCasesr_reactorrrr)r+rx)rerr poolStarter conditionrrrsf&f @@r:runAsyncDistTrialRunner.runAsynczs"u-. -- C ND$4$45//0%%    HU%9%9%;$>""$ $ $M=F? %+""$ $ $sZCED)E2D#DD#ED!ED#!E#D>7D:8D>>EcB<V^8dQhRS[S[S[3,RS[RS[/#)r=testrr>)r rrrr)r?rSs"r:r@rs,*0*0x23*04*0I*0r9caaaaRoRoRV3RllpRVVV3RllpRVV3RllpSPPRR V4\P!SP W44P V4P V4oSPP 4\S\4'dSP4\S\4'g QS R 24h\\SP4#) NFcJV^8dQhR\\\3,RR/#)r=rr>N)r rr()r?s"r:r@*DistTrialRunner._run..__annotate__s$  uWl23  r9c <VoR#r_r2)rrs&r:capture%DistTrialRunner._run..capturesFr9cPV^8dQhR\\\,,/#r<)r robject)r?s"r:r@rs  &)9 : r9c8<RoSfSP4S#R#)TN)cancel)reactorStoppingrtestsInProgresssr:maybeStopTests,DistTrialRunner._run..maybeStopTestss""O~&&(&&r9c0V^8dQhR\R\/#)r=rr>)r)r?s"r:r@rs  V  r9cL<S'gSPP4V#r_)rstop)rrres&r:maybeStopReactor.DistTrialRunner._run..maybeStopReactors" ""$Mr9beforeshutdownz is not DistReporter)raddSystemEventTriggerrrlraddBothrf isinstancerraiseExceptionr(r rr) rerrrrrrrrs f&& @@@r:_runDistTrialRunner._runs59 %       ++Hj.Q  " "4==#D E WW  W% &   fg & &  ! ! # &,//PF8;O1PP/Iv//r9c<<V^8dQhRS[S[S[3,RS[/#r=rr>r rrr)r?rSs"r:r@rs%33h 123y3r9c (VPVRR7#)zI Run a reactor and a test suite. @param test: The test or suite to run. Frrrers&&r:rfDistTrialRunner.runs yyEy22r9c<<V^8dQhRS[S[S[3,RS[/#rr)r?rSs"r:r@rs%22E(I*=$>292r9c (VPVRR7#)zd Run the tests with local worker processes until they fail. @param test: The test or suite to run. Trrrs&&r:runUntilFailureDistTrialRunner.runUntilFailures yyDy11r9c<V^8dQh/S[RS[3,;R&S[;R&S[S[,;R&S[;R&S[;R&S[;R&S[;R&S[;R &S[;R &S[;R &S[;R &S[S[.S[ 3,;R &#)r=.rrrrrrrrrrrr) rrrQrrRrr1r rKr|)r?rSs"r:r@r!s,sI~..-./03i1234 5@ OAD%EF!GH"IJKL*MN!"2!3Z!?@MOr9r2)F)"r3r4r5r6r7r(rrrorrrrIrrstdoutrrrrrrr|rrrrrrrfrrUr8rVrWs@r:rr!s (hGJ"'!/:#H 4?3::3NOF%!O"H*CM 3 3:J%J%X*0*0X3322sr9r)Nr7rr functoolsros.pathrtypingrrrrrr r r r r unittestrrattrsrrrattrs.convertersrtwisted.internet.deferrrrtwisted.internet.interfacesrrtwisted.loggerrtwisted.python.failurertwisted.python.filepathrtwisted.python.lockfilertwisted.python.modulesr _asyncrunnerritrialrr rr!runnerr"utilr#r$r%r& distreporterr( functionalr)r*r+r,rar-r.r/r1rIrKrYr|rrrr2r9r:r4s     )'',HHE!*,20()543&MM== o E(*5"5"5"pb b b J 3F$^2^2^2r9