chore: reformatted 3 files

Author: hsilan

emulator/src/aws_lambda_durable_functions_emulator/config.py

@@ -59,13 +59,17 @@ def __post_init__(self):
 
     def to_web_service_config(self):
         """Convert to testing library web service config."""
-        return WebServiceConfig(host=self.host, port=self.port, log_level=self.log_level)
+        return WebServiceConfig(
+            host=self.host, port=self.port, log_level=self.log_level
+        )
 
     def _validate_config(self):
         """Validate all configuration parameters."""
 
         # Validate Lambda endpoint URL
-        def _raise_invalid_endpoint(endpoint: str, cause: Exception | None = None) -> None:
+        def _raise_invalid_endpoint(
+            endpoint: str, cause: Exception | None = None
+        ) -> None:
             msg = f"Invalid Lambda endpoint URL: {endpoint}"
             raise ValueError(msg) from cause
 
@@ -79,11 +83,15 @@ def _raise_invalid_endpoint(endpoint: str, cause: Exception | None = None) -> No
         # Validate storage directory if specified
         if self.storage_dir:
 
-            def _raise_storage_error(storage_dir: str, cause: Exception | None = None) -> None:
+            def _raise_storage_error(
+                storage_dir: str, cause: Exception | None = None
+            ) -> None:
                 msg = f"Storage directory is not writable: {storage_dir}"
                 raise ValueError(msg) from cause
 
-            def _raise_access_error(storage_dir: str, cause: Exception | None = None) -> None:
+            def _raise_access_error(
+                storage_dir: str, cause: Exception | None = None
+            ) -> None:
                 msg = f"Cannot access storage directory: {storage_dir}"
                 raise ValueError(msg) from cause
 
@@ -107,7 +115,13 @@ def _raise_access_error(storage_dir: str, cause: Exception | None = None) -> Non
                 _raise_access_error(self.storage_dir, e)
 
         # Validate log level
-        valid_log_levels = [logging.DEBUG, logging.INFO, logging.WARNING, logging.ERROR, logging.CRITICAL]
+        valid_log_levels = [
+            logging.DEBUG,
+            logging.INFO,
+            logging.WARNING,
+            logging.ERROR,
+            logging.CRITICAL,
+        ]
         if self.log_level not in valid_log_levels:
             msg = f"Invalid log level: {self.log_level}. Must be one of {valid_log_levels}"
             raise ValueError(msg)

emulator/src/aws_lambda_durable_functions_emulator/factory.py

@@ -7,7 +7,9 @@
 
 import aws_durable_execution_sdk_python
 import botocore.loaders
-from aws_durable_execution_sdk_python_testing.checkpoint.processor import CheckpointProcessor
+from aws_durable_execution_sdk_python_testing.checkpoint.processor import (
+    CheckpointProcessor,
+)
 from aws_durable_execution_sdk_python_testing.executor import Executor
 from aws_durable_execution_sdk_python_testing.invoker import LambdaInvoker
 from aws_durable_execution_sdk_python_testing.scheduler import Scheduler
@@ -85,7 +87,9 @@ def create_executor(config: "EmulatorConfig"):
         store = TestingLibraryComponentFactory.create_store(config)
         scheduler = TestingLibraryComponentFactory.create_scheduler()
         invoker = TestingLibraryComponentFactory.create_invoker(config)
-        checkpoint_processor = TestingLibraryComponentFactory.create_checkpoint_processor(store, scheduler)
+        checkpoint_processor = (
+            TestingLibraryComponentFactory.create_checkpoint_processor(store, scheduler)
+        )
 
         executor = Executor(store, scheduler, invoker, checkpoint_processor)
         checkpoint_processor.add_execution_observer(executor)

emulator/src/aws_lambda_durable_functions_emulator/server.py

@@ -22,7 +22,9 @@
 
 # Configure logging
 log_level = get_log_level()
-logging.basicConfig(level=log_level, format="%(asctime)s - %(name)s - %(levelname)s - %(message)s")
+logging.basicConfig(
+    level=log_level, format="%(asctime)s - %(name)s - %(levelname)s - %(message)s"
+)
 logger = logging.getLogger("durable_functions_emulator")
 logger.setLevel(log_level)
 
@@ -66,7 +68,9 @@ def start(self):
         try:
             logger.info("Starting emulator server...")
             with self.web_server:
-                logger.info("Server listening on %s:%s", self.config.host, self.config.port)
+                logger.info(
+                    "Server listening on %s:%s", self.config.host, self.config.port
+                )
                 self.web_server.serve_forever()
         except KeyboardInterrupt:
             logger.info("Server shutdown requested by user")
@@ -79,17 +83,31 @@ def start(self):
 
 def main():
     """Main entry point for the emulator server."""
-    parser = argparse.ArgumentParser(description="AWS Lambda Durable Functions Emulator (powered by testing library)")
-    parser.add_argument("--host", type=str, help="Host to bind to (default: from HOST env var or 0.0.0.0)")
-    parser.add_argument("--port", type=int, help="Port to bind to (default: from PORT env var or 5000)")
+    parser = argparse.ArgumentParser(
+        description="AWS Lambda Durable Functions Emulator (powered by testing library)"
+    )
+    parser.add_argument(
+        "--host",
+        type=str,
+        help="Host to bind to (default: from HOST env var or 0.0.0.0)",
+    )
+    parser.add_argument(
+        "--port", type=int, help="Port to bind to (default: from PORT env var or 5000)"
+    )
     args = parser.parse_args()
 
     try:
         # Create emulator configuration
-        config = EmulatorConfig(host=args.host or get_host(), port=args.port or get_port())
+        config = EmulatorConfig(
+            host=args.host or get_host(), port=args.port or get_port()
+        )
 
         # Create and start emulator server
-        logger.info("Starting AWS Lambda Durable Functions Emulator on %s:%s", config.host, config.port)
+        logger.info(
+            "Starting AWS Lambda Durable Functions Emulator on %s:%s",
+            config.host,
+            config.port,
+        )
         server = EmulatorServer(config)
         server.start()
 
@@ -105,7 +123,9 @@ def main():
 
     except ImportError:
         logger.exception("Missing dependency")
-        logger.info("Please install the aws-durable-execution-sdk-python-testing package:")
+        logger.info(
+            "Please install the aws-durable-execution-sdk-python-testing package:"
+        )
         logger.info("  pip install aws-durable-execution-sdk-python-testing")
         sys.exit(1)