Fixing Spelling, and making missing objectstore message an INFO log.

Author: angelosantos4

nodestream/cli/operations/initialize_logger.py

@@ -4,7 +4,7 @@
 
 from pythonjsonlogger.jsonlogger import JsonFormatter
 
-from nodestream.cli.commands.nodestream_command import BaseCommand
+from nodestream.cli.commands.nodestream_command import NodestreamCommand
 from nodestream.metrics import Metrics
 from nodestream.logging_metrics import MetricsLoggingHandler
 from .operation import Operation
@@ -40,6 +40,6 @@ def record_factory(*args, **kwargs):
 
 
 class InitializeLogger(Operation):
-    async def perform(self, command: BaseCommand) -> Any:
+    async def perform(self, command: NodestreamCommand) -> Any:
         if command.has_json_logging_set:
             configure_logging_with_json_defaults()

nodestream/pipeline/object_storage.py

@@ -253,7 +253,7 @@ 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.")
+        logger.info("Using null ObjectStore. No persistence is configured.")
 
     def get(self, _: str) -> Optional[bytes]:
         return None

nodestream/project/run_request.py

@@ -56,4 +56,4 @@ async def execute_with_definition(self, definition: PipelineDefinition):
         await pipeline.run(self.progress_reporter)
 
     def set_configuration(self, scope_config: ScopeConfig):
-        self.initialization_arguments.effecitve_config_values = scope_config
+        self.initialization_arguments.effective_config_values = scope_config

tests/unit/pipeline/test_pipeline_file.py

@@ -70,7 +70,7 @@ def test_pipeline_file_loads_lazy():
 
 def test_pipeline_file_loads_config_when_set():
     init_args = PipelineInitializationArguments(
-        effecitve_config_values=ScopeConfig({"name": "test"})
+        effective_config_values=ScopeConfig({"name": "test"})
     )
     file_contents = PipelineFileContents.read_from_file(
         Path("tests/unit/pipeline/fixtures/config_pipeline.yaml")