From 4174d67084a4df947ae3b3bdefa3c3023c6c64ab Mon Sep 17 00:00:00 2001 From: Bulat Kurbanov Date: Tue, 22 Apr 2025 01:17:42 +0200 Subject: [PATCH] Fix --- src/applications/schedule_sync/workflows/sync.py | 1 + src/applications/twitch_webhook/workflows/checker.py | 1 + src/applications/twitch_webhook/workflows/on_channel_update.py | 2 ++ 3 files changed, 4 insertions(+) diff --git a/src/applications/schedule_sync/workflows/sync.py b/src/applications/schedule_sync/workflows/sync.py index a0fe9c5..4cf4f23 100644 --- a/src/applications/schedule_sync/workflows/sync.py +++ b/src/applications/schedule_sync/workflows/sync.py @@ -36,5 +36,6 @@ class ScheduleSyncWorkflow: await workflow.start_activity( syncronize, streamer.twitch.id, + task_queue=MAIN_QUEUE, schedule_to_close_timeout=timedelta(minutes=5), ) diff --git a/src/applications/twitch_webhook/workflows/checker.py b/src/applications/twitch_webhook/workflows/checker.py index 54c655c..98bfc91 100644 --- a/src/applications/twitch_webhook/workflows/checker.py +++ b/src/applications/twitch_webhook/workflows/checker.py @@ -28,5 +28,6 @@ class StreamsCheckWorkflow: async def run(self): await workflow.start_activity( check_streams_states, + task_queue=MAIN_QUEUE, schedule_to_close_timeout=timedelta(minutes=1) ) diff --git a/src/applications/twitch_webhook/workflows/on_channel_update.py b/src/applications/twitch_webhook/workflows/on_channel_update.py index b8271b3..7190f5f 100644 --- a/src/applications/twitch_webhook/workflows/on_channel_update.py +++ b/src/applications/twitch_webhook/workflows/on_channel_update.py @@ -7,6 +7,7 @@ from twitchAPI.helper import first from applications.twitch_webhook.state import UpdateEvent, EventType, State from applications.twitch_webhook.twitch.authorize import authorize from applications.twitch_webhook.activities.on_state_change import on_stream_state_change_activity, OnStreamStateChangeActivity +from applications.temporal_worker.queues import MAIN_QUEUE @workflow.defn @@ -34,5 +35,6 @@ class OnChannelUpdateWorkflow: last_live_at=datetime.now(timezone.utc) ), ), + task_queue=MAIN_QUEUE, schedule_to_close_timeout=timedelta(minutes=1) )