Skip to content

Commit

Permalink
Revert sleep time to 1.1 from 2.0 (#41)
Browse files Browse the repository at this point in the history
Apparently there's a hardcoded value of `1.2` in https://github.com/faust-streaming/mode/blob/17c5d2996e4706baa37b18bd8fa03687409120ad/mode/timers.py#L13 so we may have made a terrible mistake.
  • Loading branch information
wbarnha authored Jan 10, 2023
1 parent 17c5d29 commit 5260fa1
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion mode/threads.py
Original file line number Diff line number Diff line change
Expand Up @@ -181,7 +181,7 @@ async def start(self) -> None:

async def _keepalive2(self) -> None:
while not self.should_stop:
await self.sleep(2.0)
await self.sleep(1.1)
if self.last_wakeup_at:
if monotonic() - self.last_wakeup_at > 3.0:
self.log.error("Thread keepalive is not responding...")
Expand Down

0 comments on commit 5260fa1

Please sign in to comment.