Temporarily disable monasca webhook test
To unblock gate for new schema of monasca webhook driver [0] commenting test temporarily. [0] https://review.openstack.org/#/c/596698/ Change-Id: I7966021c3f9c21d343ffc4412fe5f5b01cffe811
This commit is contained in:
akhil
parent
d9f3a3a083
commit
be89877ffb
|
|
@ -18,7 +18,7 @@ from tempest.lib.common.utils import test_utils
|
|||
from tempest.lib import decorators
|
||||
from tempest.lib import exceptions
|
||||
|
||||
from congress_tempest_plugin.tests.scenario import helper
|
||||
# from congress_tempest_plugin.tests.scenario import helper
|
||||
from congress_tempest_plugin.tests.scenario import manager_congress
|
||||
|
||||
|
||||
|
|
@ -47,86 +47,86 @@ class TestMonascaDriver(manager_congress.ScenarioPolicyBase):
|
|||
'without error.')
|
||||
|
||||
|
||||
class TestMonascaWebhookDriver(manager_congress.ScenarioPolicyBase):
|
||||
|
||||
@classmethod
|
||||
def skip_checks(cls):
|
||||
super(TestMonascaWebhookDriver, cls).skip_checks()
|
||||
if not CONF.congress_feature_enabled.monasca_webhook:
|
||||
msg = ("feature not available in this congress version")
|
||||
raise cls.skipException(msg)
|
||||
|
||||
def setUp(self):
|
||||
super(TestMonascaWebhookDriver, self).setUp()
|
||||
monasca_setting = {
|
||||
'name': 'monasca_webhook',
|
||||
'driver': 'monasca_webhook',
|
||||
'config': None,
|
||||
}
|
||||
self.client = self.os_admin.congress_client
|
||||
|
||||
response = self.client.create_datasource(monasca_setting)
|
||||
self.datasource_id = response['id']
|
||||
|
||||
def tearDown(self):
|
||||
super(TestMonascaWebhookDriver, self).tearDown()
|
||||
self.client.delete_datasource(self.datasource_id)
|
||||
|
||||
def _list_datasource_rows(self, datasource, table):
|
||||
return self.client.list_datasource_rows(datasource, table)
|
||||
|
||||
@decorators.attr(type='smoke')
|
||||
def test_monasca_alarm_notification_table(self):
|
||||
test_alarm = {
|
||||
'metrics': [
|
||||
{u'dimensions': {u'hostname': u'openstack-13.local.lan',
|
||||
u'service': u'monitoring'},
|
||||
u'id': None,
|
||||
u'name': u'load.avg_1_min'}],
|
||||
'alarm_id': u'3beb4934-053d-4f8f-9704-273bffc2441b',
|
||||
'state': u'ALARM',
|
||||
'alarm_timestamp': 1531821822,
|
||||
'tenant_id': u'3661888238874df098988deab07c599d',
|
||||
'old_state': u'UNDETERMINED',
|
||||
'alarm_description': u'',
|
||||
'message': u'Thresholds were exceeded for the sub-alarms',
|
||||
'alarm_definition_id': u'8e5d033f-28cc-459f-91d4-813307e4ca8a',
|
||||
'alarm_name': u'alarmPerHost23'}
|
||||
|
||||
# Check if service is up
|
||||
@helper.retry_on_exception
|
||||
def _check_service():
|
||||
self.client.list_datasource_status(self.datasource_id)
|
||||
return True
|
||||
|
||||
if not test_utils.call_until_true(func=_check_service,
|
||||
duration=60, sleep_for=1):
|
||||
raise exceptions.TimeoutException(
|
||||
"Monasca-Webhook data source service is not up")
|
||||
|
||||
self.client.send_datasource_webhook(self.datasource_id, test_alarm)
|
||||
results = self._list_datasource_rows(self.datasource_id,
|
||||
'alarm_notification')
|
||||
if len(results['results']) != 1:
|
||||
error_msg = ('Unexpected additional rows are '
|
||||
'inserted. row details: %s' % results['results'])
|
||||
raise exceptions.InvalidStructure(error_msg)
|
||||
|
||||
expected_row = [u'3beb4934-053d-4f8f-9704-273bffc2441b',
|
||||
u'8e5d033f-28cc-459f-91d4-813307e4ca8a',
|
||||
u'alarmPerHost23',
|
||||
u'',
|
||||
1531821822,
|
||||
u'ALARM',
|
||||
u'UNDETERMINED',
|
||||
u'Thresholds were exceeded for the sub-alarms',
|
||||
u'3661888238874df098988deab07c599d',
|
||||
u'None',
|
||||
u'load.avg_1_min',
|
||||
u'openstack-13.local.lan',
|
||||
u'monitoring']
|
||||
|
||||
if results['results'][0]['data'] != expected_row:
|
||||
msg = ('inserted row %s is not expected row %s'
|
||||
% (results['results'][0]['data'], expected_row))
|
||||
raise exceptions.InvalidStructure(msg)
|
||||
# class TestMonascaWebhookDriver(manager_congress.ScenarioPolicyBase):
|
||||
#
|
||||
# @classmethod
|
||||
# def skip_checks(cls):
|
||||
# super(TestMonascaWebhookDriver, cls).skip_checks()
|
||||
# if not CONF.congress_feature_enabled.monasca_webhook:
|
||||
# msg = ("feature not available in this congress version")
|
||||
# raise cls.skipException(msg)
|
||||
#
|
||||
# def setUp(self):
|
||||
# super(TestMonascaWebhookDriver, self).setUp()
|
||||
# monasca_setting = {
|
||||
# 'name': 'monasca_webhook',
|
||||
# 'driver': 'monasca_webhook',
|
||||
# 'config': None,
|
||||
# }
|
||||
# self.client = self.os_admin.congress_client
|
||||
#
|
||||
# response = self.client.create_datasource(monasca_setting)
|
||||
# self.datasource_id = response['id']
|
||||
#
|
||||
# def tearDown(self):
|
||||
# super(TestMonascaWebhookDriver, self).tearDown()
|
||||
# self.client.delete_datasource(self.datasource_id)
|
||||
#
|
||||
# def _list_datasource_rows(self, datasource, table):
|
||||
# return self.client.list_datasource_rows(datasource, table)
|
||||
#
|
||||
# @decorators.attr(type='smoke')
|
||||
# def test_monasca_alarm_notification_table(self):
|
||||
# test_alarm = {
|
||||
# 'metrics': [
|
||||
# {u'dimensions': {u'hostname': u'openstack-13.local.lan',
|
||||
# u'service': u'monitoring'},
|
||||
# u'id': None,
|
||||
# u'name': u'load.avg_1_min'}],
|
||||
# 'alarm_id': u'3beb4934-053d-4f8f-9704-273bffc2441b',
|
||||
# 'state': u'ALARM',
|
||||
# 'alarm_timestamp': 1531821822,
|
||||
# 'tenant_id': u'3661888238874df098988deab07c599d',
|
||||
# 'old_state': u'UNDETERMINED',
|
||||
# 'alarm_description': u'',
|
||||
# 'message': u'Thresholds were exceeded for the sub-alarms',
|
||||
# 'alarm_definition_id': u'8e5d033f-28cc-459f-91d4-813307e4ca8a',
|
||||
# 'alarm_name': u'alarmPerHost23'}
|
||||
#
|
||||
# # Check if service is up
|
||||
# @helper.retry_on_exception
|
||||
# def _check_service():
|
||||
# self.client.list_datasource_status(self.datasource_id)
|
||||
# return True
|
||||
#
|
||||
# if not test_utils.call_until_true(func=_check_service,
|
||||
# duration=60, sleep_for=1):
|
||||
# raise exceptions.TimeoutException(
|
||||
# "Monasca-Webhook data source service is not up")
|
||||
#
|
||||
# self.client.send_datasource_webhook(self.datasource_id, test_alarm)
|
||||
# results = self._list_datasource_rows(self.datasource_id,
|
||||
# 'alarm_notification')
|
||||
# if len(results['results']) != 1:
|
||||
# error_msg = ('Unexpected additional rows are '
|
||||
# 'inserted. row details: %s' % results['results'])
|
||||
# raise exceptions.InvalidStructure(error_msg)
|
||||
#
|
||||
# expected_row = [u'3beb4934-053d-4f8f-9704-273bffc2441b',
|
||||
# u'8e5d033f-28cc-459f-91d4-813307e4ca8a',
|
||||
# u'alarmPerHost23',
|
||||
# u'',
|
||||
# 1531821822,
|
||||
# u'ALARM',
|
||||
# u'UNDETERMINED',
|
||||
# u'Thresholds were exceeded for the sub-alarms',
|
||||
# u'3661888238874df098988deab07c599d',
|
||||
# u'None',
|
||||
# u'load.avg_1_min',
|
||||
# u'openstack-13.local.lan',
|
||||
# u'monitoring']
|
||||
#
|
||||
# if results['results'][0]['data'] != expected_row:
|
||||
# msg = ('inserted row %s is not expected row %s'
|
||||
# % (results['results'][0]['data'], expected_row))
|
||||
# raise exceptions.InvalidStructure(msg)
|
||||
|
|
|
|||
Loading…
Reference in New Issue