diff options
| author | bd <bdunahu@operationnull.com> | 2025-12-08 17:38:29 -0500 |
|---|---|---|
| committer | bd <bdunahu@operationnull.com> | 2025-12-08 17:38:29 -0500 |
| commit | 782050b9b648ef788e5695a5556b401d4ab66849 (patch) | |
| tree | 0a43f1d2b8bad5d188da544205c9af5c9bd41370 /nemesis | |
| parent | ec6d6cb0d8200843080e28a217fc0a5cd80db2e3 (diff) | |
nemesis/causal_event_loop.py: remove line profiler
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: |