twisted.trial._dist.disttrial.DistTrialRunner : API documentation

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.

_workerNumber = (source)

the number of workers to be spawned.

(type: int)

_stream = (source)

stream which the reporter will use.

_reporterFactory = (source)

the reporter class to be used.

def _makeResult(self): (source)

Make reporter factory, and wrap it with a DistReporter.

def __init__(self, reporterFactory, workerNumber, workerArguments, stream=None, tracebackFormat='default', realTimeErrors=False, uncleanWarnings=False, logfile='test.log', workingDirectory='_trial_temp'): (source)

Undocumented

_workerArguments = (source)

Undocumented

_tbformat = (source)

Undocumented

_rterrors = (source)

Undocumented

_uncleanWarnings = (source)

Undocumented

_result = (source)

Undocumented

_workingDirectory = (source)

Undocumented

_logFile = (source)

Undocumented

_logFileObserver = (source)

Undocumented

_logFileObject = (source)

Undocumented

_logWarnings = (source)

Undocumented

(type: bool)

def writeResults(self, result): (source)

Write test run final outcome to result.

Parameters result A TestResult which will print errors and the summary.

def createLocalWorkers(self, protocols, workingDirectory): (source)

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.

def launchWorkerProcesses(self, spawner, protocols, arguments): (source)

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.

def _driveWorker(self, worker, result, testCases, cooperate): (source)

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.

def run(self, suite, reactor=None, cooperate=cooperate, untilFailure=False): (source)

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`)

def runUntilFailure(self, suite): (source)

Run the tests with local worker processes until they fail.

Parameters suite A tests suite to be run.