From 95152c15a794165a4998efa0f5bf2998084440da Mon Sep 17 00:00:00 2001 From: Bulat Kurbanov Date: Sun, 17 Nov 2024 13:40:04 +0100 Subject: [PATCH] Fix --- src/modules/scheduler_sync/tasks.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/modules/scheduler_sync/tasks.py b/src/modules/scheduler_sync/tasks.py index 7de13d4..cf2de7b 100644 --- a/src/modules/scheduler_sync/tasks.py +++ b/src/modules/scheduler_sync/tasks.py @@ -3,7 +3,7 @@ from repositories.streamers import StreamerConfigRepository from .synchronizer import syncronize -@broker.task() +@broker.task("scheduler_sync.syncronize_task") async def syncronize_task(twitch_id: int): 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) -@broker.task(schedule=[{"cron": "*/5 * * * *"}]) +@broker.task("scheduler_sync.syncronize_all_task", schedule=[{"cron": "*/5 * * * *"}]) async def syncronize_all_task(): streamers = await StreamerConfigRepository().all()