kurbezz/discord-bot
1
0
Fork 0
mirror of https://github.com/kurbezz/discord-bot.git synced 2026-03-03 11:30:46 +01:00
Code Issues Packages Projects Releases Wiki Activity

Fix

Browse Source
This commit is contained in:
Bulat Kurbanov
2025-04-22 01:17:42 +02:00
parent 2d8b767ae3
commit 4174d67084
3 changed files with 4 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
src/applications/schedule_sync/workflows/sync.py
View File

@@ -36,5 +36,6 @@ class ScheduleSyncWorkflow:
await workflow.start_activity( await workflow.start_activity(
syncronize, syncronize,
streamer.twitch.id, streamer.twitch.id,
task_queue=MAIN_QUEUE,
schedule_to_close_timeout=timedelta(minutes=5), schedule_to_close_timeout=timedelta(minutes=5),
) )

1
src/applications/twitch_webhook/workflows/checker.py
View File

@@ -28,5 +28,6 @@ class StreamsCheckWorkflow:
async def run(self): async def run(self):
await workflow.start_activity( await workflow.start_activity(
check_streams_states, check_streams_states,
task_queue=MAIN_QUEUE,
schedule_to_close_timeout=timedelta(minutes=1) schedule_to_close_timeout=timedelta(minutes=1)
) )

2
src/applications/twitch_webhook/workflows/on_channel_update.py
View File

@@ -7,6 +7,7 @@ from twitchAPI.helper import first
from applications.twitch_webhook.state import UpdateEvent, EventType, State from applications.twitch_webhook.state import UpdateEvent, EventType, State
from applications.twitch_webhook.twitch.authorize import authorize 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.twitch_webhook.activities.on_state_change import on_stream_state_change_activity, OnStreamStateChangeActivity
from applications.temporal_worker.queues import MAIN_QUEUE
@workflow.defn @workflow.defn
@@ -34,5 +35,6 @@ class OnChannelUpdateWorkflow:
last_live_at=datetime.now(timezone.utc) last_live_at=datetime.now(timezone.utc)
), ),
), ),
task_queue=MAIN_QUEUE,
schedule_to_close_timeout=timedelta(minutes=1) schedule_to_close_timeout=timedelta(minutes=1)
) )