From b94bc1e02eda3b6ed85fc7571f16d1a90ec12915 Mon Sep 17 00:00:00 2001 From: DevilXD Date: Sun, 27 Mar 2022 19:38:03 +0200 Subject: [PATCH] Fix maintenance task restart logic --- twitch.py | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/twitch.py b/twitch.py index d742435..29e4fd1 100644 --- a/twitch.py +++ b/twitch.py @@ -171,9 +171,11 @@ class Twitch: self._watching_task.cancel() self._watching_task = asyncio.create_task(self._watch_loop()) # NOTE: maintenance task is restarted only if it finished unexpectedly early - if self._mnt_task is not None and self._mnt_task.done() and not self._mnt_task.cancelled(): + if self._mnt_task is not None and self._mnt_task.done(): self._mnt_task.cancel() - self._mnt_task = asyncio.create_task(self._maintenance_loop()) + self._mnt_task = None + if self._mnt_task is None or self._mnt_task.done(): + self._mnt_task = asyncio.create_task(self._maintenance_loop()) # Add default topics assert self._user_id is not None self.websocket.add_topics([