fix: start runners early to compensate for deferred scheduling

sardine_core/scheduler/async_runner.py

@@ -273,6 +273,11 @@ def defer_beats(self) -> float:
         """The number of beats to defer function calls."""
         return float(self.scheduler.deferred)
 
+    @property
+    def defer_duration(self) -> float:
+        """The amount of time to defer function calls."""
+        return self.defer_beats * self.clock.beat_duration
+
     @property
     def env(self) -> "FishBowl":
         """A shorthand for the scheduler's fish bowl."""
@@ -676,10 +681,11 @@ async def _run_once(self) -> None:
         arriving_states: list[DeferredState] = []
         while self.deferred_states:
             entry = self.deferred_states[0]
+            entry_deadline = entry.deadline - self.defer_duration
             if (
-                self.clock.time >= entry.deadline
+                self.clock.time >= entry_deadline
                 or state is not None
-                and deadline >= entry.deadline
+                and deadline >= entry_deadline
             ):
                 heapq.heappop(self.deferred_states)
 
@@ -709,7 +715,7 @@ async def _run_once(self) -> None:
             # sleeping a full period.
             deadline = self.deferred_states[0].deadline
             # interrupted is true if we are past the deadline
-            interrupted = await self._sleep_until(deadline)
+            interrupted = await self._sleep_until(deadline - self.defer_duration)
             return self._jump_start_iteration()
 
         # NOTE: deadline will always be defined at this point
@@ -745,7 +751,7 @@ async def _call_func(self, func, args, kwargs):
 
         if self.defer_beats:
             delta = self.clock.time - self._expected_time
-            shift = self.defer_beats * self.clock.beat_duration - delta
+            shift = self.defer_duration - delta
             self.time.shift += shift
 
         return await maybe_coro(func, *args, **valid_kwargs)