Loading src/monitoring/tests/Messages.py +2 −2 Original line number Diff line number Diff line Loading @@ -127,8 +127,8 @@ def alarm_descriptor_b(): def alarm_subscription(alarm_id): _alarm_subscription = monitoring_pb2.AlarmSubscription() subscription_timeout_s = 20 subscription_frequency_ms = 3000 subscription_timeout_s = 10 subscription_frequency_ms = 1000 _alarm_subscription.alarm_id.alarm_id.uuid = str(alarm_id.alarm_id.uuid) _alarm_subscription.subscription_timeout_s = subscription_timeout_s Loading src/monitoring/tests/test_unitary.py +0 −32 Original line number Diff line number Diff line Loading @@ -523,38 +523,6 @@ def test_subscription_manager_create_subscription(management_db,metrics_db,subs_ assert total_points != 0 def test_alarm_manager_create_alarm(management_db,metrics_db): LOGGER.warning('test_alarm_manager_create_alarm begin') _alarm_description = "Alarm Description" _alarm_name = "Alarm Name" _kpi_id = "3" _kpi_min_value = 0.0 _kpi_max_value = 250.0 _in_range = True _include_min_value = False _include_max_value = True _subscription_frequency_ms = 10 _alarm_id = management_db.insert_alarm(_alarm_description, _alarm_name, _kpi_id, _kpi_min_value, _kpi_max_value, _in_range, _include_min_value, _include_max_value) LOGGER.debug(f"alarm_id: {_alarm_id}") _alarm_queue = Queue() _alarm_manager = AlarmManager(metrics_db) _alarm_manager.create_alarm(_alarm_queue,str(_alarm_id),_kpi_id,_kpi_min_value,_kpi_max_value,_in_range,_include_min_value,_include_max_value,_subscription_frequency_ms) LOGGER.debug(_alarm_queue) while not _alarm_queue.empty(): list = _alarm_queue.get_nowait() LOGGER.debug(list) for item in list: LOGGER.debug(item) def test_events_tools( context_client : ContextClient, # pylint: disable=redefined-outer-name device_client : DeviceClient, # pylint: disable=redefined-outer-name Loading Loading
src/monitoring/tests/Messages.py +2 −2 Original line number Diff line number Diff line Loading @@ -127,8 +127,8 @@ def alarm_descriptor_b(): def alarm_subscription(alarm_id): _alarm_subscription = monitoring_pb2.AlarmSubscription() subscription_timeout_s = 20 subscription_frequency_ms = 3000 subscription_timeout_s = 10 subscription_frequency_ms = 1000 _alarm_subscription.alarm_id.alarm_id.uuid = str(alarm_id.alarm_id.uuid) _alarm_subscription.subscription_timeout_s = subscription_timeout_s Loading
src/monitoring/tests/test_unitary.py +0 −32 Original line number Diff line number Diff line Loading @@ -523,38 +523,6 @@ def test_subscription_manager_create_subscription(management_db,metrics_db,subs_ assert total_points != 0 def test_alarm_manager_create_alarm(management_db,metrics_db): LOGGER.warning('test_alarm_manager_create_alarm begin') _alarm_description = "Alarm Description" _alarm_name = "Alarm Name" _kpi_id = "3" _kpi_min_value = 0.0 _kpi_max_value = 250.0 _in_range = True _include_min_value = False _include_max_value = True _subscription_frequency_ms = 10 _alarm_id = management_db.insert_alarm(_alarm_description, _alarm_name, _kpi_id, _kpi_min_value, _kpi_max_value, _in_range, _include_min_value, _include_max_value) LOGGER.debug(f"alarm_id: {_alarm_id}") _alarm_queue = Queue() _alarm_manager = AlarmManager(metrics_db) _alarm_manager.create_alarm(_alarm_queue,str(_alarm_id),_kpi_id,_kpi_min_value,_kpi_max_value,_in_range,_include_min_value,_include_max_value,_subscription_frequency_ms) LOGGER.debug(_alarm_queue) while not _alarm_queue.empty(): list = _alarm_queue.get_nowait() LOGGER.debug(list) for item in list: LOGGER.debug(item) def test_events_tools( context_client : ContextClient, # pylint: disable=redefined-outer-name device_client : DeviceClient, # pylint: disable=redefined-outer-name Loading