Skip to content

Commit 6c36ebb

Browse files
committed
fix: remove minimum time from scan interlock
1 parent fda0c80 commit 6c36ebb

1 file changed

Lines changed: 1 addition & 7 deletions

File tree

bec_server/bec_server/actors/actor.py

Lines changed: 1 addition & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -66,13 +66,10 @@ class SubscriptionActor(ActorBase):
6666
"""An actor which subscribes to a list of redis endpoints, and evaluates on any message to any
6767
of those endpoints."""
6868

69-
min_delay_s: float = 0.01
70-
7169
def __init__(self, client: BECClient, name: str, exec_id: str):
7270
super().__init__(client, name, exec_id)
7371
self._endpoints = self.default_monitor_endpoints()
7472
self._stopped = False
75-
self.last_evaluated = 0
7673

7774
logger.info(f"Setting up {self.__class__.__name__}: {self._endpoints}.")
7875
for endpoint in self._endpoints:
@@ -89,10 +86,7 @@ def default_monitor_callbacks(self) -> list[Callable]:
8986
def evaluate(self, *_, **__):
9087
if self._stopped:
9188
return
92-
if (now := time.monotonic()) < self.last_evaluated + self.min_delay_s:
93-
return
94-
logger.debug(f"{self.__class__.__name__} evaluated")
95-
self.last_evaluated = now
89+
logger.debug(f"{self.__class__.__name__} evaluating")
9690
return super().evaluate(*_, **__)
9791

9892
def run(self):

0 commit comments

Comments
 (0)