class DistTrialRunner: (source)
A specialized runner for distributed trial. The runner launches a number of local worker processes which will run tests.
Method | __init__ |
Undocumented |
Method | writeResults |
Write test run final outcome to result. |
Method | createLocalWorkers |
Create local worker protocol instances and return them. |
Method | launchWorkerProcesses |
Spawn processes from a list of process protocols. |
Method | run |
Spawn local worker processes and load tests. After that, run them. |
Method | runUntilFailure |
Run the tests with local worker processes until they fail. |
Instance Variable | _workerNumber |
the number of workers to be spawned. |
Instance Variable | _stream |
stream which the reporter will use. |
Instance Variable | _reporterFactory |
the reporter class to be used. |
Method | _makeResult |
Make reporter factory, and wrap it with a DistReporter . |
Instance Variable | _workerArguments |
Undocumented |
Instance Variable | _tbformat |
Undocumented |
Instance Variable | _rterrors |
Undocumented |
Instance Variable | _uncleanWarnings |
Undocumented |
Instance Variable | _result |
Undocumented |
Instance Variable | _workingDirectory |
Undocumented |
Instance Variable | _logFile |
Undocumented |
Instance Variable | _logFileObserver |
Undocumented |
Instance Variable | _logFileObject |
Undocumented |
Instance Variable | _logWarnings |
Undocumented |
Method | _driveWorker |
Drive a LocalWorkerAMP instance, iterating the tests and calling run for every one of them. |
Undocumented
Write test run final outcome to result.
Parameters | result | A TestResult which will print errors and the summary. |
Create local worker protocol instances and return them.
Parameters | protocols | An iterable of LocalWorkerAMP instances. |
workingDirectory | The base path in which we should run the workers. (type: str ) | |
Returns | A list of quantity LocalWorker instances. |
Spawn processes from a list of process protocols.
Parameters | spawner | A IReactorProcess.spawnProcess implementation. |
protocols | An iterable of ProcessProtocol instances. | |
arguments | Extra arguments passed to the processes. |
Drive a LocalWorkerAMP
instance, iterating the tests and calling run
for every one of them.
Parameters | worker | The LocalWorkerAMP to drive. |
result | The global DistReporter instance. | |
testCases | The global list of tests to iterate. | |
cooperate | The cooperate function to use, to be customized in tests. (type: function ) | |
Returns | A Deferred firing when all the tests are finished. |
Spawn local worker processes and load tests. After that, run them.
Parameters | suite | A tests suite to be run. |
reactor | The reactor to use, to be customized in tests. (type: A provider of twisted.internet.interfaces.IReactorProcess ) | |
cooperate | The cooperate function to use, to be customized in tests. (type: function ) | |
untilFailure | If True , continue to run the tests until they fail. (type: bool .) | |
Returns | The test result. (type: DistReporter ) |