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

Part of lp.services.twistedsupport.tests.test_task View In Hierarchy

Tests for ParallelLimitedTaskConsumer.
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.
def makeConsumer(self, worker_limit=None):
Make a consumer for testing.
Parametersworker_limitThe maximum number of concurrent workers. If None, then default to an unreasonably large number so that it won't interfere with tests.
ReturnsA ParallelLimitedTaskConsumer.
def _neverEndingTask(self):
A task that never completes.

Just return a deferred that we will never fire.

def test_implements_ITaskConsumer(self):
Undocumented
def test_consume_starts_source(self):
Undocumented
def test_consume_twice_raises_error(self):
Undocumented
def test_consumer_doesnt_finish_until_tasks_finish(self):
Undocumented
def test_consumer_finishes_if_no_tasks_found(self):
Undocumented
def test_consumer_doesnt_finish_until_stop_deferred_fires(self):
Undocumented
def test_consumer_doesnt_finish_if_stop_doesnt_stop(self):
Undocumented
def test_consumer_doesnt_finish_if_no_tasks_found_and_job_running(self):
Undocumented
def test_source_not_stopped_if_no_tasks_found_and_job_running(self):
Undocumented
def test_source_started_when_all_tasks_done(self):
Undocumented
def test_taskStarted_before_consume_raises_error(self):
Undocumented
def test_taskProductionFailed_before_consume_raises_error(self):
Undocumented
def test_taskStarted_runs_task(self):
Undocumented
def test_taskStarted_restarts_source(self):
Undocumented
def test_reaching_working_limit_stops_source(self):
Undocumented
def test_passing_working_limit_stops_source(self):
Undocumented
def test_run_task_even_though_passed_limit(self):
Undocumented
def test_restart_source_when_worker_available(self):
Undocumented
def test_production_failed_stops_source(self):
Undocumented
def test_failure_before_any_tasks_stops_consumer(self):
Undocumented
def test_one_failure_doesnt_stop_consumer(self):
Undocumented
API Documentation for Launchpad, generated by pydoctor at 2018-08-18 00:00:04.