#133 indicator anomaly detection [WIP DO NOT MERGE]

db/init/06-indicator-type.sql

@@ -38,4 +38,5 @@ INSERT INTO base.indicator_type (name, module, class, method) VALUES
   ('Completeness', 'completeness', 'Completeness', 'execute')
 , ('Freshness', 'freshness', 'Freshness', 'execute')
 , ('Latency', 'latency', 'Latency', 'execute')
-, ('Validity', 'validity', 'Validity', 'execute');
+, ('Validity', 'validity', 'Validity', 'execute')
+, ('Anomaly Detection', 'anomaly_detection', 'AnomalyDetection', 'execute');

scripts/init/anomaly_detection.py

@@ -0,0 +1,13 @@
+"""Manage class and methods for data anomaly indicators."""
+import logging
+from indicator import Indicator
+
+# Load logging configuration
+log = logging.getLogger(__name__)
+
+
+class AnomalyDetection(Indicator):
+    """Class used to compute indicators of type anomaly detection."""
+
+    def execute(self, session: dict):
+        pass

scripts/init/batch.py

@@ -7,6 +7,7 @@
 import freshness  # Called dynamically with getattr pylint: disable=W0611
 import latency  # Called dynamically with getattr pylint: disable=W0611
 import validity  # Called dynamically with getattr pylint: disable=W0611
+import anomaly_detection  # Called dynamically with getattr pylint: disable=W0611
 import utils
 from session import update_session_status
 

scripts/init/constants.py

@@ -21,3 +21,4 @@ class IndicatorType:
     FRESHNESS = 2
     LATENCY = 3
     VALIDITY = 4
+    ANOMALY_DETECTION = 5