kurbezz/discord-bot
1
0
Fork 0
mirror of https://github.com/kurbezz/discord-bot.git synced 2025-12-06 15:15:37 +01:00
Code Issues Packages Projects Releases Wiki Activity

Fix

Browse Source
This commit is contained in:
Bulat Kurbanov
2024-11-17 13:40:04 +01:00
parent a34265cf9d
commit 95152c15a7
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/modules/scheduler_sync/tasks.py
View File

@@ -3,7 +3,7 @@ from repositories.streamers import StreamerConfigRepository
from .synchronizer import syncronize from .synchronizer import syncronize
@broker.task() @broker.task("scheduler_sync.syncronize_task")
async def syncronize_task(twitch_id: int): async def syncronize_task(twitch_id: int):
streamer = await StreamerConfigRepository.get_by_twitch_id(twitch_id) streamer = await StreamerConfigRepository.get_by_twitch_id(twitch_id)
@@ -13,7 +13,7 @@ async def syncronize_task(twitch_id: int):
await syncronize(streamer.twitch, streamer.integrations.discord.guild_id) await syncronize(streamer.twitch, streamer.integrations.discord.guild_id)
@broker.task(schedule=[{"cron": "*/5 * * * *"}]) @broker.task("scheduler_sync.syncronize_all_task", schedule=[{"cron": "*/5 * * * *"}])
async def syncronize_all_task(): async def syncronize_all_task():
streamers = await StreamerConfigRepository().all() streamers = await StreamerConfigRepository().all()