ensure requests can't collide

WISDEM · Sep 15, 2023 · a709162 · a709162
1 parent e745030
commit a709162
Showing 1 changed file with 18 additions and 2 deletions.
diff --git a/wombat/core/service_equipment.py b/wombat/core/service_equipment.py
@@ -1647,6 +1647,12 @@ def run_scheduled_in_situ(self) -> Generator[Process, None, None]:
                     )
                 )
 
+            # Avoid requests for the same system and therefore a timing collision
+            seconds_to_wait, *_ = (
+                self.env.random_generator.integers(low=0, high=10, size=1) / 3600.0
+            )
+            yield self.env.timeout(seconds_to_wait)
+
             request = self.get_next_request()
             if request is None:
                 if not self.at_port:
@@ -1739,6 +1745,12 @@ def run_unscheduled_in_situ(self) -> Generator[Process, None, None]:
             return
 
         while True and self.env.now < charter_end_env_time:
+            # Avoid requests for the same system and therefore a timing collision
+            seconds_to_wait, *_ = (
+                self.env.random_generator.integers(low=0, high=10, size=1) / 3600.0
+            )
+            yield self.env.timeout(seconds_to_wait)
+
             request = self.get_next_request()
             if request is None:
                 yield self.env.process(
@@ -1823,8 +1835,12 @@ def run_unscheduled_in_situ(self) -> Generator[Process, None, None]:
                     )
                 )
 
-            # Wait one second to ensure there are no timing collisions
-            yield self.env.timeout(1.0 / 3600)
+            # Avoid requests for the same system and therefore a timing collision
+            seconds_to_wait, *_ = (
+                self.env.random_generator.integers(low=0, high=10, size=1) / 3600.0
+            )
+            yield self.env.timeout(seconds_to_wait)
+
             request = self.get_next_request()
             if request is None:
                 yield self.env.process(