Mirror/iSponsorBlockTV
1
0
Fork 0
mirror of https://github.com/dmunozv04/iSponsorBlockTV.git synced 2025-12-06 11:56:45 +03:00
Code Issues Packages Projects Releases Wiki Activity

[pre-commit.ci] auto fixes from pre-commit.com hooks

Browse Source 
for more information, see https://pre-commit.ci
This commit is contained in:
pre-commit-ci[bot]
2025-05-14 21:54:36 +00:00
parent a6dacc1d84
commit b2dfe35698
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/iSponsorBlockTV/ytlounge.py
View File

@@ -53,13 +53,13 @@ class YtLoungeApi(pyytlounge.YtLoungeApi):
await asyncio.sleep(10) await asyncio.sleep(10)
current_time = asyncio.get_event_loop().time() current_time = asyncio.get_event_loop().time()
time_since_last_event = current_time - self.last_event_time time_since_last_event = current_time - self.last_event_time
# YouTube sends a message at least every 30 seconds # YouTube sends a message at least every 30 seconds
if time_since_last_event > 60: if time_since_last_event > 60:
self.logger.debug( self.logger.debug(
f"Watchdog triggered: No events for {time_since_last_event:.1f} seconds" f"Watchdog triggered: No events for {time_since_last_event:.1f} seconds"
) )
# Cancel current subscription # Cancel current subscription
if self.subscribe_task and not self.subscribe_task.done(): if self.subscribe_task and not self.subscribe_task.done():
self.subscribe_task.cancel() self.subscribe_task.cancel()
@@ -74,7 +74,7 @@ class YtLoungeApi(pyytlounge.YtLoungeApi):
# Subscribe to the lounge and start the watchdog # Subscribe to the lounge and start the watchdog
async def subscribe_monitored(self, callback): async def subscribe_monitored(self, callback):
self.callback = callback self.callback = callback
# Stop existing watchdog if running # Stop existing watchdog if running
if self.subscribe_task_watchdog and not self.subscribe_task_watchdog.done(): if self.subscribe_task_watchdog and not self.subscribe_task_watchdog.done():
self.watchdog_running = False self.watchdog_running = False