diff options
Diffstat (limited to 'nemesis')
| -rw-r--r-- | nemesis/causal_event_loop.py | 5 |
1 files changed, 0 insertions, 5 deletions
diff --git a/nemesis/causal_event_loop.py b/nemesis/causal_event_loop.py index dc807aa..628fecd 100644 --- a/nemesis/causal_event_loop.py +++ b/nemesis/causal_event_loop.py @@ -22,7 +22,6 @@ from typing import TYPE_CHECKING, Any, Callable, Self if TYPE_CHECKING: import contextvars -import line_profiler import asyncio import collections # TODO remove dependency @@ -200,7 +199,6 @@ class CausalEventLoop(asyncio.SelectorEventLoop): ): self._ready_events[e] = curr_time - @line_profiler.profile def update_ready(self: Any) -> None: """ Polls the IO selector, schedules resulting callbacks, and schedules @@ -262,7 +260,6 @@ class CausalEventLoop(asyncio.SelectorEventLoop): self._add_ready_handles() # self._logger.info(f"\tscheduled now size: {len(self._scheduled)}") - @line_profiler.profile def _run_once(self: Any) -> None: """ Run one full iteration of the event loop. @@ -319,7 +316,6 @@ class CausalEventLoop(asyncio.SelectorEventLoop): self._current_handle = None handle = None # Needed to break cycles when an exception occurs. - @line_profiler.profile def _get_next_effective_time(self): """ Returns the delta time in which the next currently processing callback @@ -343,7 +339,6 @@ class CausalEventLoop(asyncio.SelectorEventLoop): heapq.heappush(self._scheduled, (eff_true, handle)) return min(next_effective_time, MAXIMUM_SELECT_TIMEOUT) - @line_profiler.profile def _add_ready_handles(self): curr_time = self.time() + self._clock_resolution while self._scheduled: |