summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorJenkins <jenkins@review.openstack.org>2016-09-16 14:09:06 +0000
committerGerrit Code Review <review@openstack.org>2016-09-16 14:09:06 +0000
commit2cc53a9a9218a9b145c27c2b55a5b36ed4a649d0 (patch)
tree07e7da12f995017687261309dae18236d6d51966
parent922657e58c1c75c9c1fdefb8052cc0a651e6825d (diff)
parent92f30acb0b843ca7eb37b45dd2a41b533d0f1998 (diff)
downloadceilometer-stable/newton.tar.gz
Merge "agentbase: remove flaky test"7.0.0.0rc1stable/newton
-rw-r--r--ceilometer/tests/unit/agent/agentbase.py28
1 files changed, 0 insertions, 28 deletions
diff --git a/ceilometer/tests/unit/agent/agentbase.py b/ceilometer/tests/unit/agent/agentbase.py
index 6543329d..9170230b 100644
--- a/ceilometer/tests/unit/agent/agentbase.py
+++ b/ceilometer/tests/unit/agent/agentbase.py
@@ -328,34 +328,6 @@ class BaseAgentManagerTestCase(base.BaseTestCase):
self.mgr.terminate()
mpc.stop.assert_called_once_with()
- @mock.patch('ceilometer.pipeline.setup_polling')
- def test_start_with_pipeline_poller(self, setup_polling):
- self.mgr.setup_polling_tasks = mock.MagicMock()
- mpc = self.mgr.partition_coordinator
- mpc.is_active.return_value = False
- self.CONF.set_override('heartbeat', 1.0, group='coordination')
- self.mgr.partition_coordinator.heartbeat = mock.MagicMock()
-
- self.CONF.set_override('refresh_pipeline_cfg', True)
- self.CONF.set_override('pipeline_polling_interval', 5)
- self.mgr.run()
- self.addCleanup(self.mgr.terminate)
- setup_polling.assert_called_once_with()
- mpc.start.assert_called_with()
- self.assertEqual(2, mpc.join_group.call_count)
- self.mgr.setup_polling_tasks.assert_called_once_with()
-
- # Wait first heatbeat
- runs = 0
- for i in six.moves.range(10):
- runs = list(self.mgr.heartbeat_timer.iter_watchers())[0].runs
- if runs > 0:
- break
- time.sleep(0.5)
- self.assertGreaterEqual(1, runs)
-
- self.assertEqual([], list(self.mgr.polling_periodics.iter_watchers()))
-
def test_join_partitioning_groups(self):
self.mgr.discoveries = self.create_discoveries()
self.mgr.join_partitioning_groups()