summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorJenkins <jenkins@review.openstack.org>2016-07-08 19:58:06 +0000
committerGerrit Code Review <review@openstack.org>2016-07-08 19:58:06 +0000
commit66e2399a45ec9fcb3aaf35b1df850d5a3ec6d658 (patch)
tree97f848393fe3b25b48e52119c1d30994e66b5aeb
parent20358b1ff011c73e763aac46e954d432e82c4940 (diff)
parent6e21e3192058f58e19596b7eb7c9cfa887bd49e2 (diff)
downloadtaskflow-66e2399a45ec9fcb3aaf35b1df850d5a3ec6d658.tar.gz
Merge "Make tests less dependent on transient state"
-rw-r--r--taskflow/tests/unit/worker_based/test_worker.py5
1 files changed, 2 insertions, 3 deletions
diff --git a/taskflow/tests/unit/worker_based/test_worker.py b/taskflow/tests/unit/worker_based/test_worker.py
index 498e350..0e49a56 100644
--- a/taskflow/tests/unit/worker_based/test_worker.py
+++ b/taskflow/tests/unit/worker_based/test_worker.py
@@ -33,7 +33,6 @@ class TestWorker(test.MockTestCase):
self.broker_url = 'test-url'
self.exchange = 'test-exchange'
self.topic = 'test-topic'
- self.endpoint_count = 29
# patch classes
self.executor_mock, self.executor_inst_mock = self.patchClass(
@@ -159,7 +158,7 @@ class TestWorker(test.MockTestCase):
def test_derive_endpoints_from_string_modules(self):
endpoints = worker.Worker._derive_endpoints(['taskflow.tests.utils'])
- self.assertEqual(self.endpoint_count, len(endpoints))
+ assert any(e.name == self.task_name for e in endpoints)
def test_derive_endpoints_from_string_non_existent_module(self):
tasks = ['non.existent.module']
@@ -190,7 +189,7 @@ class TestWorker(test.MockTestCase):
def test_derive_endpoints_from_modules(self):
endpoints = worker.Worker._derive_endpoints([utils])
- self.assertEqual(self.endpoint_count, len(endpoints))
+ assert any(e.name == self.task_name for e in endpoints)
def test_derive_endpoints_unexpected_task_type(self):
self.assertRaises(TypeError, worker.Worker._derive_endpoints, [111])