Adding the logging inside the null obj constructor

Author: AGhafaryy

nodestream/pipeline/object_storage.py

@@ -1,6 +1,7 @@
 import base64
 import hashlib
 import hmac
+import logging
 import pickle
 from abc import ABC, abstractmethod
 from dataclasses import dataclass
@@ -13,6 +14,9 @@
 from ..subclass_registry import SubclassRegistry
 from .extractors.credential_utils import AwsClientFactory
 
+logger = logging.getLogger(__name__)
+
+
 OBJECT_STORE_REGISTRY = SubclassRegistry(ignore_overrides=True)
 T = TypeVar("T")
 
@@ -248,6 +252,9 @@ def delete(self, key: str):
 class NullObjectStore(ObjectStore, alias="null"):
     """An object store that does not store any objects."""
 
+    def __init__(self):
+        logger.error("Using null ObjectStore. No persistence is configured.")
+
     def get(self, _: str) -> Optional[bytes]:
         return None
 

nodestream/project/storage.py

@@ -1,4 +1,3 @@
-import logging
 from dataclasses import dataclass, field
 from typing import Any, Dict, Optional, Union
 
@@ -61,8 +60,6 @@ class StorageConfiguration:
 
     def initialize_by_name(self, name: str) -> ObjectStore:
         if name not in self.storage_configuration_by_name:
-            logger = logging.getLogger(__name__)
-            logger.info(f"Store configuration '{name}' not found.")
             return ObjectStore.null()
 
         return self.storage_configuration_by_name[name].initialize()