From 782050b9b648ef788e5695a5556b401d4ab66849 Mon Sep 17 00:00:00 2001 From: bd Date: Mon, 8 Dec 2025 17:38:29 -0500 Subject: nemesis/causal_event_loop.py: remove line profiler --- nemesis/causal_event_loop.py | 5 ----- 1 file changed, 5 deletions(-) (limited to 'nemesis') 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: -- cgit v1.2.3