EaZyCode/twitch-miner-docker
1
0 Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Make sure watch task is protected by task_wrapper

Browse Source
This commit is contained in:
DevilXD committed 2022-01-14 18:52:55 +01:00
1 parent 3f19174b20
commit 9b51cf079b
1 file changed
+2
Download Patch File Download Diff File Expand all files Collapse all files
twitch.py
+2
View File
@@ -316,6 +316,7 @@ class Twitch:
self.change_state(State.CHANNELS_CLEANUP) self.change_state(State.CHANNELS_CLEANUP)
await self._state_change.wait() await self._state_change.wait()
@task_wrapper
async def _watch_loop(self) -> None: async def _watch_loop(self) -> None:
interval = WATCH_INTERVAL.total_seconds() interval = WATCH_INTERVAL.total_seconds()
i = 1 i = 1
@@ -396,6 +397,7 @@ class Twitch:
self.gui.channels.set_watching(channel) self.gui.channels.set_watching(channel)
self._watching_restart.set() self._watching_restart.set()
@task_wrapper
async def process_stream_state(self, channel_id: int, message: JsonType): async def process_stream_state(self, channel_id: int, message: JsonType):
msg_type = message["type"] msg_type = message["type"]
channel = self.channels.get(channel_id) channel = self.channels.get(channel_id)