lp.services.twistedsupport.tests.test_task.TestParallelLimitedTaskConsumer : API documentation

Method	makeConsumer	Make a consumer for testing.
Method	test_implements_ITaskConsumer	Undocumented
Method	test_consume_starts_source	Undocumented
Method	test_consume_twice_raises_error	Undocumented
Method	test_consumer_doesnt_finish_until_tasks_finish	Undocumented
Method	test_consumer_finishes_if_no_tasks_found	Undocumented
Method	test_consumer_doesnt_finish_until_stop_deferred_fires	Undocumented
Method	test_consumer_doesnt_finish_if_stop_doesnt_stop	Undocumented
Method	test_consumer_doesnt_finish_if_no_tasks_found_and_job_running	Undocumented
Method	test_source_not_stopped_if_no_tasks_found_and_job_running	Undocumented
Method	test_source_started_when_all_tasks_done	Undocumented
Method	test_taskStarted_before_consume_raises_error	Undocumented
Method	test_taskProductionFailed_before_consume_raises_error	Undocumented
Method	test_taskStarted_runs_task	Undocumented
Method	test_taskStarted_restarts_source	Undocumented
Method	test_reaching_working_limit_stops_source	Undocumented
Method	test_passing_working_limit_stops_source	Undocumented
Method	test_run_task_even_though_passed_limit	Undocumented
Method	test_restart_source_when_worker_available	Undocumented
Method	test_production_failed_stops_source	Undocumented
Method	test_failure_before_any_tasks_stops_consumer	Undocumented
Method	test_one_failure_doesnt_stop_consumer	Undocumented
Method	_neverEndingTask	A task that never completes.

Inherited from TestCase:

Method	becomeDbUser	Commit, then log into the database as `dbuser`.
Method	__str__	The string representation of a test is its id.
Method	useContext	Use the supplied context in this test.
Method	makeTemporaryDirectory	Create a temporary directory, and return its path.
Method	installKarmaRecorder	Set up and return a `KarmaRecorder`.
Method	assertProvides	Assert 'obj' correctly provides 'interface'.
Method	assertNotifies	Assert that a callable performs a given notification.
Method	assertNoNotification	Assert that no notifications are generated by the callable.
Method	assertSqlAttributeEqualsDate	Fail unless the value of the attribute is equal to the date.
Method	assertTextMatchesExpressionIgnoreWhitespace	Undocumented
Method	assertIsInstance	Assert that an instance is an instance of assert_class.
Method	assertIsNot	Assert that `expected` is not the same object as `observed`.
Method	assertContentEqual	Assert that 'iter1' has the same content as 'iter2'.
Method	assertRaisesWithContent	Check if the given exception is raised with given content.
Method	assertBetween	Assert that 'variable' is strictly between two boundaries.
Method	assertVectorEqual	Apply assertEqual to all given pairs in one go.
Method	expectedLog	Expect a log to be written that matches the regex.
Method	pushConfig	Push some key-value pairs into a section of the config.
Method	attachOopses	Undocumented
Method	attachLibrarianLog	Include the logChunks from fixture in the test details.
Method	setUp	Undocumented
Method	assertStatementCount	Assert that the expected number of SQL statements occurred.
Method	useTempDir	Use a temporary directory for this test.
Method	assertEmailHeadersEqual	Assert that two email headers are equal.
Method	assertStartsWith	Undocumented
Method	assertEndsWith	Asserts that s ends with suffix.
Method	checkPermissions	Check if the used_permissions match expected_permissions.
Method	assertEmailQueueLength	Pop the email queue, assert its length, and return it.
Method	_unfoldEmailHeader	Unfold a multiline email header.

Parameters	worker_limit	The maximum number of concurrent workers. If None, then default to an unreasonably large number so that it won't interfere with tests.
Returns	A `ParallelLimitedTaskConsumer`.

l.s.t.t.t.TestParallelLimitedTaskConsumer(TestCase) : class documentation