openstack/vitrage-tempest-plugin
Code Issues Proposed changes

create collector service

Browse Source 
Change-Id: Ic9f84132a41aac3215725208c3ea7fa5cb905cc6
This commit is contained in:
Alexey Weyl 2017-06-15 12:17:34 +00:00
parent 6fef0a7212
commit b0e45e62d1
11 changed files with 40 additions and 74 deletions

4
vitrage_tempest_tests/tests/api/alarms/test_alarms.py

@ -13,7 +13,6 @@
# under the License.
import json
import traceback
from oslo_log import log as logging
@ -49,8 +48,7 @@ class TestAlarms(BaseAlarmsTest):
api_alarms, cli_alarms, AODH_DATASOURCE,
utils.uni2str(instances[0].id))
except Exception as e:
LOG.exception(e)
traceback.print_exc()
self._handle_exception(e)
raise
finally:
self._delete_ceilometer_alarms()

11
vitrage_tempest_tests/tests/api/base.py

@ -13,6 +13,7 @@
# under the License.
import time
import traceback
from oslo_log import log as logging
from oslotest import base
@ -379,3 +380,13 @@ class BaseApiTest(base.BaseTestCase):
if not public_nets:
return None
return public_nets[0]
def _print_entity_graph(self):
api_graph = self.vitrage_client.topology.get(all_tenants=True)
graph = self._create_graph_from_graph_dictionary(api_graph)
LOG.info('Entity Graph: \n%s', graph.json_output_graph())
def _handle_exception(self, exception):
traceback.print_exc()
LOG.exception(exception)
self._print_entity_graph()

8
vitrage_tempest_tests/tests/api/datasources/test_aodh.py

@ -12,8 +12,6 @@
# License for the specific language governing permissions and limitations
# under the License.
import traceback
from oslo_log import log as logging
from vitrage_tempest_tests.tests import utils
@ -59,8 +57,7 @@ class TestAodhAlarm(BaseAlarmsTest):
num_edges,
entities)
except Exception as e:
traceback.print_exc()
LOG.exception(e)
self._handle_exception(e)
raise
finally:
self._delete_ceilometer_alarms()
@ -90,8 +87,7 @@ class TestAodhAlarm(BaseAlarmsTest):
num_edges,
entities)
except Exception as e:
traceback.print_exc()
LOG.exception(e)
self._handle_exception(e)
raise
finally:
self._delete_ceilometer_alarms()

5
vitrage_tempest_tests/tests/api/datasources/test_cinder_volume.py

@ -12,8 +12,6 @@
# License for the specific language governing permissions and limitations
# under the License.
import traceback
from oslo_log import log as logging
from vitrage_tempest_tests.tests.api.topology.base import BaseTopologyTest
from vitrage_tempest_tests.tests import utils
@ -58,8 +56,7 @@ class TestCinderVolume(BaseTopologyTest):
num_edges,
entities)
except Exception as e:
traceback.print_exc()
LOG.exception(e)
self._handle_exception(e)
raise
finally:
self._rollback_to_default()

4
vitrage_tempest_tests/tests/api/datasources/test_heat_stack.py

@ -13,7 +13,6 @@
# under the License.
import time
import traceback
from oslo_log import log as logging
from vitrage_tempest_tests.tests import utils
@ -66,8 +65,7 @@ class TestHeatStack(BaseTopologyTest):
num_edges,
entities)
except Exception as e:
traceback.print_exc()
LOG.exception(e)
self._handle_exception(e)
raise
finally:
self._delete_stacks()

5
vitrage_tempest_tests/tests/api/datasources/test_neutron.py

@ -12,8 +12,6 @@
# License for the specific language governing permissions and limitations
# under the License.
import traceback
from oslo_log import log as logging
from vitrage.common.constants import VertexProperties as VProps
@ -66,8 +64,7 @@ class TestNeutron(BaseTopologyTest):
num_edges,
entities)
except Exception as e:
traceback.print_exc()
LOG.exception(e)
self._handle_exception(e)
raise
finally:
self._delete_instances()

5
vitrage_tempest_tests/tests/api/datasources/test_nova.py

@ -12,8 +12,6 @@
# License for the specific language governing permissions and limitations
# under the License.
import traceback
from oslo_log import log as logging
from vitrage_tempest_tests.tests.api.topology.base import BaseTopologyTest
from vitrage_tempest_tests.tests import utils
@ -54,8 +52,7 @@ class TestNova(BaseTopologyTest):
num_edges,
entities)
except Exception as e:
traceback.print_exc()
LOG.exception(e)
self._handle_exception(e)
raise
finally:
self._rollback_to_default()

4
vitrage_tempest_tests/tests/api/datasources/test_static_physical.py

@ -15,7 +15,6 @@
import os
import socket
import time
import traceback
from oslo_log import log as logging
from vitrage_tempest_tests.tests.api.base import BaseApiTest
@ -57,8 +56,7 @@ class TestStaticPhysical(BaseApiTest):
num_edges,
entities)
except Exception as e:
traceback.print_exc()
LOG.exception(e)
self._handle_exception(e)
raise
finally:
self._delete_switches()

17
vitrage_tempest_tests/tests/api/rca/test_rca.py

@ -12,8 +12,6 @@
# License for the specific language governing permissions and limitations
# under the License.
import traceback
from oslo_log import log as logging
from vitrage.common.constants import VertexProperties as VProps
@ -54,8 +52,7 @@ class TestRca(BaseRcaTest):
self._compare_rca(api_rca, cli_rca)
except Exception as e:
traceback.print_exc()
LOG.exception(e)
self._handle_exception(e)
raise
finally:
self._clean_all()
@ -84,8 +81,7 @@ class TestRca(BaseRcaTest):
self._validate_relationship(links=api_rca['links'],
alarms=api_rca['nodes'])
except Exception as e:
traceback.print_exc()
LOG.exception(e)
self._handle_exception(e)
raise
finally:
self._clean_all()
@ -108,8 +104,7 @@ class TestRca(BaseRcaTest):
self._validate_deduce_alarms(alarms=api_alarms,
instances=instances)
except Exception as e:
traceback.print_exc()
LOG.exception(e)
self._handle_exception(e)
raise
finally:
self._clean_all()
@ -133,8 +128,7 @@ class TestRca(BaseRcaTest):
self._validate_set_state(topology=topology['nodes'],
instances=instances)
except Exception as e:
traceback.print_exc()
LOG.exception(e)
self._handle_exception(e)
raise
finally:
self._clean_all()
@ -159,8 +153,7 @@ class TestRca(BaseRcaTest):
self._validate_notifier(alarms=ceilometer_alarms,
vitrage_alarms=vitrage_alarms)
except Exception as e:
traceback.print_exc()
LOG.exception(e)
self._handle_exception(e)
raise
finally:
self._clean_all()

19
vitrage_tempest_tests/tests/api/resources/test_resources.py

@ -13,7 +13,6 @@
# under the License.
import json
import traceback
from oslo_log import log as logging
@ -53,8 +52,7 @@ class TestResource(BaseApiTest):
self._compare_resources(api_resources, cli_resources)
except Exception as e:
LOG.exception(e)
traceback.print_exc()
self._handle_exception(e)
raise
finally:
self._delete_instances()
@ -72,8 +70,7 @@ class TestResource(BaseApiTest):
resources = self.vitrage_client.resource.list()
self.assertEqual(4, len(resources))
except Exception as e:
LOG.exception(e)
traceback.print_exc()
self._handle_exception(e)
raise
finally:
self._delete_instances()
@ -92,8 +89,7 @@ class TestResource(BaseApiTest):
resources = self.vitrage_client.resource.list(all_tenants=True)
self.assertEqual(4, len(resources))
except Exception as e:
LOG.exception(e)
traceback.print_exc()
self._handle_exception(e)
raise
finally:
self._delete_instances()
@ -113,8 +109,7 @@ class TestResource(BaseApiTest):
all_tenants=False)
self.assertEqual(1, len(resources))
except Exception as e:
LOG.exception(e)
traceback.print_exc()
self._handle_exception(e)
raise
finally:
self._delete_instances()
@ -131,8 +126,7 @@ class TestResource(BaseApiTest):
all_tenants=False)
self.assertEqual(0, len(resources))
except Exception as e:
LOG.exception(e)
traceback.print_exc()
self._handle_exception(e)
raise
finally:
self._delete_instances()
@ -158,8 +152,7 @@ class TestResource(BaseApiTest):
self.vitrage_client.resource.show('test_for_no_existing')
self.assertIsNone(resource)
except Exception as e:
LOG.exception(e)
traceback.print_exc()
self._handle_exception(e)
raise
finally:
self._delete_instances()

32
vitrage_tempest_tests/tests/api/topology/test_topology.py

@ -12,8 +12,6 @@
# License for the specific language governing permissions and limitations
# under the License.
import traceback
from oslo_log import log as logging
from vitrage_tempest_tests.tests.api.topology.base import BaseTopologyTest
@ -90,8 +88,7 @@ class TestTopology(BaseTopologyTest):
num_edges,
entities)
except Exception as e:
traceback.print_exc()
LOG.exception(e)
self._handle_exception(e)
raise
finally:
self._rollback_to_default()
@ -127,8 +124,7 @@ class TestTopology(BaseTopologyTest):
num_edges,
entities)
except Exception as e:
traceback.print_exc()
LOG.exception(e)
self._handle_exception(e)
raise
finally:
self._rollback_to_default()
@ -162,8 +158,7 @@ class TestTopology(BaseTopologyTest):
num_edges,
entities)
except Exception as e:
traceback.print_exc()
LOG.exception(e)
self._handle_exception(e)
raise
finally:
self._rollback_to_default()
@ -192,8 +187,7 @@ class TestTopology(BaseTopologyTest):
self.num_default_edges,
entities)
except Exception as e:
traceback.print_exc()
LOG.exception(e)
self._handle_exception(e)
raise
finally:
self._rollback_to_default()
@ -222,8 +216,7 @@ class TestTopology(BaseTopologyTest):
self.num_default_edges,
entities)
except Exception as e:
traceback.print_exc()
LOG.exception(e)
self._handle_exception(e)
raise
finally:
self._rollback_to_default()
@ -257,8 +250,7 @@ class TestTopology(BaseTopologyTest):
num_edges,
entities)
except Exception as e:
traceback.print_exc()
LOG.exception(e)
self._handle_exception(e)
raise
finally:
self._rollback_to_default()
@ -290,8 +282,7 @@ class TestTopology(BaseTopologyTest):
self.num_default_edges,
entities)
except Exception as e:
traceback.print_exc()
LOG.exception(e)
self._handle_exception(e)
raise
finally:
self._rollback_to_default()
@ -328,8 +319,7 @@ class TestTopology(BaseTopologyTest):
num_edges,
entities)
except Exception as e:
traceback.print_exc()
LOG.exception(e)
self._handle_exception(e)
raise
finally:
self._rollback_to_default()
@ -383,8 +373,7 @@ class TestTopology(BaseTopologyTest):
0,
len(api_graph['links']), 'num of edges')
except Exception as e:
traceback.print_exc()
LOG.exception(e)
self._handle_exception(e)
raise
finally:
self._rollback_to_default()
@ -409,8 +398,7 @@ class TestTopology(BaseTopologyTest):
# Test Assertions
self.assertEqual({}, api_graph)
except Exception as e:
traceback.print_exc()
LOG.exception(e)
self._handle_exception(e)
raise
finally:
self._rollback_to_default()