sh-edraft.de/sh_discord_bot
4
1
Fork 1
Code Issues 21 Pull Requests Actions Packages Projects 3 Releases 27 Wiki Activity

Made watchers transient
All checks were successful
Deploy staging on push / pre-build (push) Successful in 1s
Details
Deploy staging on push / build-bot (push) Successful in 3m46s
Details
Deploy staging on push / build-web (push) Successful in 2m5s
Details
Deploy staging on push / deploy (push) Successful in 28s
Details

Browse Source
This commit is contained in:
Sven Heidemann 2023-12-10 13:13:24 +01:00
parent dfb6751bf9
commit 39299eb11b
5 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
bot/src/modules/base/base_module.py
View File

@ -62,8 +62,8 @@ class BaseModule(ModuleABC):
services.add_transient(BaseReactionHandler) services.add_transient(BaseReactionHandler)
services.add_singleton(EventService) services.add_singleton(EventService)
services.add_transient(UserWarningsService) services.add_transient(UserWarningsService)
services.add_singleton(TaskABC, BirthdayWatcher) services.add_transient(TaskABC, BirthdayWatcher)
services.add_singleton(TaskABC, ScheduledEventsWatcher) services.add_transient(TaskABC, ScheduledEventsWatcher)
# forms # forms
services.add_transient(BugReportForm) services.add_transient(BugReportForm)

2
bot/src/modules/base/tasks/birthday_watcher.py
View File

@ -37,7 +37,7 @@ class BirthdayWatcher(TaskABC):
if not self._is_maintenance(): if not self._is_maintenance():
self.watch.start() self.watch.start()
@tasks.loop(time=datetime.time(hour=8, minute=0)) @tasks.loop(time=datetime.time(hour=8, minute=0), reconnect=True)
async def watch(self): async def watch(self):
self._logger.info(__name__, "Watching birthdays") self._logger.info(__name__, "Watching birthdays")
try: try:

2
bot/src/modules/base/tasks/scheduled_events_watcher.py
View File

@ -37,7 +37,7 @@ class ScheduledEventsWatcher(TaskABC):
if not self._is_maintenance(): if not self._is_maintenance():
self.watch.start() self.watch.start()
@tasks.loop(hours=3) @tasks.loop(hours=3, reconnect=True)
async def watch(self): async def watch(self):
self._logger.info(__name__, "Watching scheduled events") self._logger.info(__name__, "Watching scheduled events")
try: try:

2
bot/src/modules/special_offers/special_offers_module.py
View File

@ -17,6 +17,6 @@ class SteamSpecialOffersModule(ModuleABC):
pass pass
def configure_services(self, services: ServiceCollectionABC, env: ApplicationEnvironmentABC): def configure_services(self, services: ServiceCollectionABC, env: ApplicationEnvironmentABC):
services.add_singleton(TaskABC, SteamOfferWatcher) services.add_transient(TaskABC, SteamOfferWatcher)
# commands # commands
# events # events

2
bot/src/modules/special_offers/steam_offer_watcher.py
View File

@ -187,7 +187,7 @@ class SteamOfferWatcher(TaskABC):
self._logger.trace(__name__, "Finished watching") self._logger.trace(__name__, "Finished watching")
return offers_for_notifications return offers_for_notifications
@tasks.loop(hours=4) @tasks.loop(hours=4, reconnect=True)
async def watch(self): async def watch(self):
self._logger.info(__name__, "Watching steam special offers") self._logger.info(__name__, "Watching steam special offers")
try: try: