t.t._.d.DistTrialRunner(object) : class documentation

Part of twisted.trial._dist.disttrial View Source View In Hierarchy

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. (type: `int`)
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`.
Method	_driveWorker	Drive a `LocalWorkerAMP` instance, iterating the tests and calling `run` for every one of them.

_workerNumber =

the number of workers to be spawned. (type: int)

_stream =

stream which the reporter will use.

_reporterFactory =

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

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.

API Documentation for Twisted, generated by pydoctor at 2013-04-03 11:20:05.