commit 01092e9c3b80f6f23130c5b3a12b1f8b4f2c7d86
author Rohan Agrawal <rohan.agrawal01@infosys.com> Mon Jun 29 10:59:59 2020 +0000
committer Rohan Agrawal <rohan.agrawal01@infosys.com> Mon Jul 13 12:14:26 2020 +0000
tree 04b7134b2a243e1a21ddf029ef5199ba3af769f1
parent 5d7e5e571e8fae2c6c5784843ce70a4096767d5f

[VOL-2570]Make skew configurable for performance metrics

Change-Id: Ifa7ab7f04c58d47a48bfa1ebd517c17ddde51358

pyvoltha/adapters/extensions/events/kpi/adapter_pm_metrics.py

diff --git a/pyvoltha/adapters/extensions/events/kpi/adapter_pm_metrics.py b/pyvoltha/adapters/extensions/events/kpi/adapter_pm_metrics.py
index 34cff6e..0a34033 100644
--- a/pyvoltha/adapters/extensions/events/kpi/adapter_pm_metrics.py
+++ b/pyvoltha/adapters/extensions/events/kpi/adapter_pm_metrics.py
@@ -40,7 +40,7 @@
     TIMESTAMP_ATTRIBUTE = 'timestamp'
 
     def __init__(self, event_mgr, core_proxy, device_id, logical_device_id, serial_number,
-                 grouped=False, freq_override=False, **kwargs):
+                 grouped=False, freq_override=False, max_skew=5, **kwargs):
         """
         Initializer for shared Device Adapter PM metrics manager
 
@@ -68,6 +68,7 @@
         self.freq_override = grouped and freq_override
         self.lc = None
         self.pm_group_metrics = dict()      # name -> PmGroupConfig
+        self.max_skew = max_skew
 
     def update(self, pm_config):
         # TODO: Move any common steps into base class