import asyncio class RestartController: def __init__(self) -> None: self._event = asyncio.Event() def request(self) -> None: self._event.set() def consume(self) -> bool: if self._event.is_set(): self._event.clear() return True return False