+ DfjJ-2Rt^RIHt^RIHtHtHtHtHtH t ^RI H t ^RI HtHt^RIHt^RIHtHt^RIHtHt^RIHt^R IHt^R IHt^R IHt^R IH t ^R I!H"t"H!t!] !R4t#RRlt$RRlt%RRlt&]!RR44t'!RR]4t(R#)zZ Test reporter forwarding test results over trial distributed AMP commands. @since: 12.3 ) TracebackType)CallableListOptionalSequenceTypeTypeVar)TestCase)Factorydefine)Literal)Deferred maybeDeferred)AMPMAX_VALUE_LENGTH)Failure)qual)managercommands) TestResult) TrialFailure)chunkstreamTc nV^8dQhR\R\R\R\R\\,RR/#)amptestName errorClasserrorframesreturnNrstrr)formats"D/usr/lib/python3/dist-packages/twisted/trial/_dist/workerreporter.py __annotate__r%s@ ),58BFs) c "\V\VPR4\44GRjxL p\VRV44GRjxL pVP \ P VVVVR7GRjxL R#LML4L 5i)a Send an error to the worker manager over an AMP connection. First the pieces which can be large are streamed over the connection. Then, L{managercommands.AddError} is called with the rest of the information and the stream IDs. @param amp: The connection to use. @param testName: The name (or ID) of the test the error relates to. @param errorClass: The fully qualified name of the error type. @param error: The string representation of the error. @param frames: The lines of the traceback associated with the error. utf-8Nc3B"TFqPR4xK R#5ir(Nencode.0frames& r$ addError..1'R6% W(=(=6)rr errorStreamIdframesStreamId)rrr,r callRemoterAddError)rrrrrr4r5s&&&&& r$addErrorr8sz"!eELL,ACS&TUUM!#'R6'RSSN ..  #%  VS3-BA=B A? +B6B7B?BBc nV^8dQhR\R\R\R\R\\,RR/#)rrrfail failClassrr Nr!)r#s"r$r%r%<s@ #&36@DS  r&c "\V\VPR4\44GRjxL p\VRV44GRjxL pVP \ P VVVVR7GRjxL R#LML4L 5i)a; Like L{addError} but for failures. @param amp: See L{addError} @param testName: See L{addError} @param failClass: The fully qualified name of the exception associated with the failure. @param fail: The string representation of the failure. @param frames: The lines of the traceback associated with the error. r(Nc3B"TFqPR4xK R#5ir*r+r-s& r$r0addFailure..Jr2r3)rr< failStreamIdr5)rrr,rr6r AddFailure)rrr;r<rr@r5s&&&&& r$ addFailurerB<sz U4;;w+?AQ%RSSL!#'R6'RSSN ..""!%  TSr9c LV^8dQhR\R\R\R\RR/#)rrrrtodor N)rr")r#s"r$r%r%Us0#SPTr&c"\V\VPR4\44GRjxL pVP \ P VVVR7GRjxL R#L1L5i)z Like L{addError} but for expected failures. @param amp: See L{addError} @param testName: See L{addError} @param error: The string representation of the expected failure. @param todo: The string description of the expectation. r(N)rr4rD)rrr,rr6rAddExpectedFailure)rrrrDr4s&&&& r$addExpectedFailurerGUs_!eELL,ACS&TUUM ..**#   Vs!-A%A!*A%A#A%#A%cva]tRt^htoRt]!]4tV3RlRltV3RlRlt V3RlRlt V3Rlt R t Vt R #) ReportingResultsaC A mutable container for the result of sending test results back to the parent process. Since it is possible for these sends to fail asynchronously but the L{TestResult} protocol is not well suited for asynchronous result reporting, results are collected on an instance of this class and when the runner believes the test is otherwise complete, it can collect the results and do something with any errors. @ivar _reporter: The L{WorkerReporter} this object is associated with. This is the object doing the result reporting. @ivar _results: A list of L{Deferred} instances representing the results of reporting operations. This is expected to grow over the course of the test run and then be inspected by the runner once the test is over. The public interface to this list is via the context manager interface. c@<V^8dQhRS[S[S[,,/#rr )rr object)r# __classdict__s"r$r%ReportingResults.__annotate__s  8HV$45 r&c VP#)ad Begin a new reportable context in which results can be collected. @return: A sequence which will contain the L{Deferred} instances representing the results of all test result reporting that happens while the context manager is active. The sequence is extended as the test runs so its value should not be consumed until the test is over. )_resultsselfs&r$ __enter__ReportingResults.__enter__s}}r&c P<V^8dQhRS[S[,RS[RS[RS[R,/#)rexcTypeexcValue excTracebackr F)r BaseExceptionrr )r#rMs"r$r%rNs<  m$   $   r&c (RVPnR#)z End the reportable context. NF) _reporter _reporting)rRrVrWrXs&&&&r$__exit__ReportingResults.__exit__s%)!r&c4<V^8dQhRS[S[,RR/#)rresultr N)r rL)r#rMs"r$r%rNs %%Xf-%$%r&c <VPPV4R#)zQ Record a L{Deferred} instance representing one test result reporting operation. N)rPappend)rRr`s&&r$recordReportingResults.records V$r&cP<V^8dQh/R;R&S[S[S[,,;R&#)rWorkerReporterr[rP)rr rL)r#rMs"r$r%rNhs), -.8F#$4/r&N)__name__ __module__ __qualname____firstlineno____doc__r listrPrSr]rc__annotate_func____static_attributes____classdictcell__)rMs@r$rIrIhs;*(/t}H    %%cr&rIc$aa]tRt^toRtRtRtV3RltV3RlRltV3RlRlt V3R lR lt V3R lR lt V3R lV3Rllt V3RlRlt V3RlV3RlltV3RlV3RlltV3RltRtRV3RlltRV3RlltRtV3RltRtVtV;t#)rfa Reporter for trial's distributed workers. We send things not through a stream, but through an C{AMP} protocol's C{callRemote} method. @ivar _DEFAULT_TODO: Default message for expected failures and unexpected successes, used only if a C{Todo} is not provided. @ivar _reporting: When a "result reporting" context is active, the corresponding context manager. Otherwise, L{None}. zTest expected to failNc 0<\SV`4WnR#)zw @param ampProtocol: The communication channel with the trial distributed manager which collects all test results. N)super__init__ ampProtocol)rRru __class__s&&r$rtWorkerReporter.__init__s &r&c <V^8dQhRS[/#rK)rI)r#rMs"r$r%WorkerReporter.__annotate__s  (8 r&c :\V4VnVP#)z Get a "result reporting" context manager. In a "result reporting" context, asynchronous test result reporting methods may be used safely. Their results (in particular, failures) are available from the context manager. )rIr\rQs&r$gatherReportingResults%WorkerReporter.gatherReportingResultss+40r&c&<V^8dQhRS[RS[/#)rrr )rr)r#rMs"r$r%rys'r&c v\V\4'd#\V^,V^,V^,4#V#)zH Convert a C{sys.exc_info()}-style tuple to a L{Failure}, if necessary. ) isinstancetupler)rRrs&&r$ _getFailureWorkerReporter._getFailures1 eU # #58U1XuQx8 8 r&c6<V^8dQhRS[RS[S[,/#)rfailurer )rrr")r#rMs"r$r%rys  ' d3i r&c  .pVPF5pVPV^,V^,\V^,4.4K7 V#)z, Extract frames from a C{Failure} instance. )rextendr")rRrrr/s&& r$ _getFramesWorkerReporter._getFramessC^^E MM58U1Xs58}= >$ r&c8<V^8dQhRS[.S[3,RR/#)rfr N)rr)r#rMs"r$r%rys#xA4r&c VPe'VPP\V44R#\R4h)aS Call L{f} if and only if a "result reporting" context is active. @param f: A function to call. Its result is accumulated into the result reporting context. It may return a L{Deferred} or a coroutine or synchronously raise an exception or return a result value. @raise ValueError: If no result reporting context is active. Nz9Cannot call command outside of reporting context manager.)r\rcr ValueError)rRrs&&r$_callWorkerReporter._calls5 ?? & OO " "=#3 4K r&c$<V^8dQhRS[RR/#)rtestr N)PyUnitTestCase)r#rMs"r$r%rys   ~  $  r&c v<aa\SS`V4VP4oSPVV3Rl4R#)zm Send a success to the parent process. This must be called in context managed by L{gatherReportingResults}. cZ<SPP\PSR7#))r)rur6r AddSuccess)rRrsr$+WorkerReporter.addSuccess..s&D$$//**X0r&N)rs addSuccessidr)rRrrrvsf&@r$rWorkerReporter.addSuccesss. 4 779   r&c*<V^8dQhRS[RS[RR/#)rrerrorObjr N)r"r)r#rMs"r$r%rys"  s l t r&c "VPV4pVP4p\VP4pVP V4p\ VP VVVV4GRjxL R#L5i)z Attempt to report an error to the parent process. Unlike L{addError} this can fail asynchronously. This version is for infrastructure code that can apply its own failure handling. @return: A L{Deferred} that fires with the result of the attempt. N)rgetErrorMessagertyperr8ru)rRrrrerrorStrrrs&&& r$addErrorFallibleWorkerReporter.addErrorFalliblesh""8,**,',,' )           sA$A/&A-'A/c*<V^8dQhRS[RS[RR/#)rrrr Nrr)r#rMs"r$r%ry s'CC^CLCTCr&c |<aaa\SS`VS4VP4oSPVVV3Rl4R#)z& Send an error to the parent process. c(<SPSS4#N)r)rrRrsr$r)WorkerReporter.addError..s4005Ar&N)rsr8rr)rRrrrrvsf&f@r$r8WorkerReporter.addError s, u%779 ABr&c*<V^8dQhRS[RS[RR/#)rrr;r Nr)r#rMs"r$r%rys"  ~ \ d r&c <aaaaa\SS`W4VP4oSPV4pVP 4o\ VP 4oSPV4oSPVVVVV3Rl4R#)z Send a Failure over. c6<\SPSSSS4#r)rBru)r<failureMessagerrRrsr$r+WorkerReporter.addFailure.. sJ   r&N) rsrBrrrrrrr) rRrr;rr<rrrrvs f&& @@@@r$rBWorkerReporter.addFailuresm 4&779""4( 002& )    r&c <aaa\SS`VS4\S4oVP4oSP VVV3Rl4R#)z Send a skip over. c\<SPP\PSSR7#))rreason)rur6rAddSkip)rrRrsr$r(WorkerReporter.addSkip..1s(D$$//''(60r&N)rsaddSkipr"rr)rRrrrrvsf&f@r$rWorkerReporter.addSkip)s8 f%V779   r&c :Vf VP#VP#)zR Get the reason for a C{Todo}. If C{todo} is L{None}, return a sensible default. ) _DEFAULT_TODOr)rRrDs&&r$_getTodoReasonWorkerReporter._getTodoReason6s <%% %;; r&c <aaaa\SS`WS4VP4oVP4oSP VVVV3Rl4R#)z Send an expected failure over. cT<\SPSSSPS4R7#))rrrD)rGrur) errorMessagerRrrDsr$r3WorkerReporter.addExpectedFailure..Is(&  !"((. r&N)rsrGrrr)rRrrrDrrrvsf&&f@@r$rG!WorkerReporter.addExpectedFailureAs> "45,,. 779   r&c |<aaa\SS`VS4VP4oSPVVV3Rl4R#)z" Send an unexpected success over. cz<SPP\PSSP S4R7#))rrD)rur6rAddUnexpectedSuccessr)rRrrDsr$r5WorkerReporter.addUnexpectedSuccess..Xs5D$$//44!((.0r&N)rsaddUnexpectedSuccessrr)rRrrDrrvsf&f@r$r#WorkerReporter.addUnexpectedSuccessQs0 $T40779   r&c R#)z I{Don't} print a summary NrgrQs&r$ printSummaryWorkerReporter.printSummary_sr&cB<V^8dQh/S[;R&S[S[,;R&#)rrur\)rrrI)r#rMs"r$r%rys%)*1r&)r\rur)rhrirjrkrlrr\rtr{rrrrrr8rBrrrGrrrnrorp __classcell__)rvrMs@@r$rfrfs ,M.2J'    $     *CC  (      }r&rfN))rltypesrtypingrrrrrrunittestr rattrsr r r twisted.internet.deferr rtwisted.protocols.amprrtwisted.python.failurertwisted.python.reflectrtwisted.trial._distrtwisted.trial.reporterrreporterrrrrr8rBrGrIrfrgr&r$rsv   DD/!:7*'/-#! CL:2&5%5%5%pA ZA r&