diff options
author | Jenkins <jenkins@review.openstack.org> | 2016-09-16 14:09:06 +0000 |
---|---|---|
committer | Gerrit Code Review <review@openstack.org> | 2016-09-16 14:09:06 +0000 |
commit | 2cc53a9a9218a9b145c27c2b55a5b36ed4a649d0 (patch) | |
tree | 07e7da12f995017687261309dae18236d6d51966 | |
parent | 922657e58c1c75c9c1fdefb8052cc0a651e6825d (diff) | |
parent | 92f30acb0b843ca7eb37b45dd2a41b533d0f1998 (diff) | |
download | ceilometer-stable/newton.tar.gz |
Merge "agentbase: remove flaky test"7.0.0.0rc1stable/newton
-rw-r--r-- | ceilometer/tests/unit/agent/agentbase.py | 28 |
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() |