Add CALL logging to the maintenance task
This commit is contained in:
1 parent
706cecec23
commit
61304a2843
1 file changed
+13
-4
@@ -1040,21 +1040,30 @@ class Twitch:
|
|||||||
trigger_cleanup = True
|
trigger_cleanup = True
|
||||||
self._mnt_triggers.popleft()
|
self._mnt_triggers.popleft()
|
||||||
next_trigger = switch_trigger
|
next_trigger = switch_trigger
|
||||||
|
logger.log(
|
||||||
|
CALL,
|
||||||
|
(
|
||||||
|
f"Maintenance task waiting until: {next_trigger.strftime('%X')} "
|
||||||
|
f"({'Cleanup' if trigger_cleanup else 'Reload'})"
|
||||||
|
)
|
||||||
|
)
|
||||||
await asyncio.sleep((next_trigger - now).total_seconds())
|
await asyncio.sleep((next_trigger - now).total_seconds())
|
||||||
# exit after waiting, before the actions
|
# exit after waiting, before the actions
|
||||||
now = datetime.now(timezone.utc)
|
now = datetime.now(timezone.utc)
|
||||||
if now >= next_period:
|
if now >= next_period:
|
||||||
break
|
break
|
||||||
if trigger_cleanup:
|
if trigger_cleanup:
|
||||||
|
logger.log(CALL, "Maintenance task requests channels cleanup")
|
||||||
self.change_state(State.CHANNELS_CLEANUP)
|
self.change_state(State.CHANNELS_CLEANUP)
|
||||||
# ensure that we don't have unclaimed points bonus
|
# ensure that we don't have unclaimed points bonus
|
||||||
channel = self.watching_channel.get_with_default(None)
|
watching_channel = self.watching_channel.get_with_default(None)
|
||||||
if channel is not None:
|
if watching_channel is not None:
|
||||||
try:
|
try:
|
||||||
await channel.claim_bonus()
|
await watching_channel.claim_bonus()
|
||||||
except Exception:
|
except Exception:
|
||||||
pass # we intentionally silently skip anything else
|
pass # we intentionally silently skip anything else
|
||||||
# this triggers this task restart every (up to) 60 minutes
|
# this triggers this task restart every (up to) 60 minutes
|
||||||
|
logger.log(CALL, "Maintenance task requests reload")
|
||||||
self.change_state(State.INVENTORY_FETCH)
|
self.change_state(State.INVENTORY_FETCH)
|
||||||
|
|
||||||
def can_watch(self, channel: Channel) -> bool:
|
def can_watch(self, channel: Channel) -> bool:
|
||||||
|
|||||||
Reference in new issue
Block a user