BDS query first from local object storage

#143

emf/model_retriever/model_retriever.py

@@ -7,7 +7,9 @@
 
 from emf.common.config_parser import parse_app_properties
 from emf.common.integrations import elastic, opdm, minio_api
+from emf.common.integrations.object_storage import models
 from emf.common.converters import opdm_metadata_to_json
+from emf.loadflow_tool.merge import latest_boundary
 from emf.loadflow_tool.model_validator.validator import validate_model
 from emf.loadflow_tool.helper import load_opdm_data
 
@@ -83,9 +85,16 @@ def handle(self, opdm_objects: dict, **kwargs):
 
 class HandlerModelsStat:
 
+    def __init__(self):
+        self.opdm_service = opdm.OPDM()
+
     def handle(self, opdm_objects: List[dict], **kwargs):
+
         # Get the latest boundary set for validation
-        latest_boundary = self.opdm_service.get_latest_boundary() # TODO - get BDS from ELK+MINIO
+        latest_boundary = models.get_latest_boundary()
+
+        if not latest_boundary:
+            latest_boundary = self.opdm_service.get_latest_boundary()
 
         # Extract statistics
         for opdm_object in opdm_objects:
@@ -106,8 +115,12 @@ def __init__(self):
         self.opdm_service = opdm.OPDM()
 
     def handle(self, opdm_objects: List[dict], **kwargs):
+
         # Get the latest boundary set for validation
-        latest_boundary = self.opdm_service.get_latest_boundary()
+        latest_boundary = models.get_latest_boundary()
+
+        if not latest_boundary:
+            latest_boundary = self.opdm_service.get_latest_boundary()
 
         logger.info(f"Validation parameters used: {VALIDATION_LOAD_FLOW_SETTINGS}")