Features/simulation runner (#10)

* added the first method to the simulation runner

* added methods to handle nodes

* completed simulation runtime + integration test

Author: GioeleB00

poetry.lock

@@ -16,13 +16,15 @@ pydantic = {extras = ["email"], version = "^2.11.7"}
 numpy = "^2.3.1"
 simpy = "^4.1.1"
 matplotlib = "^3.10.3"
+pyyaml = "^6.0.2"
 
 [tool.poetry.group.dev.dependencies]
 pytest = "^8.4.1"
 pytest-asyncio = "^1.0.0"
 pytest-cov = "^6.2.1"
 mypy = "^1.16.1"
 ruff = "^0.12.1"
+types-pyyaml = "^6.0.12.20250516"
 
 [build-system]
 requires = ["poetry-core"]

pyproject.toml

@@ -158,9 +158,11 @@ def get_latency_stats(self) -> dict[LatencyKey, float]:
         return self.latency_stats or {}
 
     def get_throughput_series(self) -> tuple[list[float], list[float]]:
-        """Return throughput time series (timestamps, RPS)."""
+        """Return (timestamps, RPS).  Empty lists when no traffic."""
         self.process_all_metrics()
-        assert self.throughput_series is not None
+        if self.throughput_series is None:
+            return [], []
+
         return self.throughput_series
 
     def get_sampled_metrics(self) -> dict[str, dict[str, list[float]]]:

src/app/metrics/analyzer.py

@@ -35,7 +35,7 @@ def __init__(
         self,
         *,
         env: simpy.Environment,
-        out_edge: EdgeRuntime,
+        out_edge: EdgeRuntime | None,
         rqs_generator_data: RqsGeneratorInput,
         sim_settings: SimulationSettings,
         rng: np.random.Generator | None = None,

src/app/runtime/actors/rqs_generator.py

@@ -29,18 +29,30 @@
 class ServerRuntime:
     """class to define the server during the simulation"""
 
-    def __init__(  # noqa: PLR0913
+    def __init__( # noqa: PLR0913
         self,
         *,
         env: simpy.Environment,
         server_resources: ServerContainers,
         server_config: Server,
-        out_edge: EdgeRuntime,
+        out_edge: EdgeRuntime | None,
         server_box: simpy.Store,
         settings: SimulationSettings,
         rng: np.random.Generator | None = None,
-    ) -> None:
-        """Docstring to complete"""
+        ) -> None:
+        """
+        Definition of the instance attributes
+        Args:
+            env (simpy.Environment): simpy environment
+            server_resources (ServerContainers):resource defined in the
+                input for each server
+            server_config (Server): parameter to define the server from the input
+            out_edge (EdgeRuntime): edge connecting the server to the next node
+            server_box (simpy.Store): box with the states that the server
+                should elaborate
+            settings (SimulationSettings): general input settings for the simulation
+            rng (np.random.Generator | None, optional): random number generator.
+        """
         self.env = env
         self.server_resources = server_resources
         self.server_config = server_config
@@ -231,6 +243,7 @@ def _handle_request( # noqa: PLR0915, PLR0912, C901
             self._ram_in_use -= total_ram
             yield self.server_resources[ServerResourceName.RAM.value].put(total_ram)
 
+        assert self.out_edge is not None
         self.out_edge.transport(state)
 
 
@@ -263,7 +276,6 @@ def _dispatcher(self) -> Generator[simpy.Event, None, None]:
         The main dispatcher loop. It pulls requests from the inbox and
         spawns a new '_handle_request' process for each one.
         """
-        assert self.out_edge is not None
         while True:
             # Wait for a request to arrive in the server's inbox
             raw_state = yield self.server_box.get()