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

Fix

Browse Source
This commit is contained in:
Bulat Kurbanov
2025-04-21 23:58:08 +02:00
parent cb464ad9f3
commit 2ef3148d46
5 changed files with 16 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

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

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

@@ -1,4 +1,4 @@
from datetime import datetime, timezone
from datetime import datetime, timezone, timedelta
from temporalio import workflow
@@ -33,5 +33,6 @@ class OnChannelUpdateWorkflow:
category=event.category_name,
last_live_at=datetime.now(timezone.utc)
),
)
),
schedule_to_close_timeout=timedelta(minutes=1)
)

3
src/applications/twitch_webhook/workflows/on_message.py
View File

@@ -1,3 +1,5 @@
from datetime import timedelta
from temporalio import workflow
from applications.twitch_webhook.messages_proc import MessageEvent
@@ -13,4 +15,5 @@ class OnMessageWorkflow:
on_message_activity,
message,
task_queue=MAIN_QUEUE,
schedule_to_close_timeout=timedelta(minutes=1)
)

5
src/applications/twitch_webhook/workflows/on_reward_redemption.py
View File

@@ -1,3 +1,5 @@
from datetime import timedelta
from temporalio import workflow
from applications.twitch_webhook.activities.redemption_reward import on_redemption_reward_add_activity
@@ -12,5 +14,6 @@ class OnRewardRedemptionWorkflow:
await workflow.start_activity(
on_redemption_reward_add_activity,
reward,
task_queue=MAIN_QUEUE
task_queue=MAIN_QUEUE,
schedule_to_close_timeout=timedelta(minutes=1)
)

5
src/applications/twitch_webhook/workflows/on_stream_online.py
View File

@@ -1,3 +1,5 @@
from datetime import timedelta
from temporalio import workflow
from applications.twitch_webhook.activities.on_state_change import on_stream_state_change_activity, OnStreamStateChangeActivity
@@ -15,5 +17,6 @@ class OnStreamOnlineWorkflow:
streamer_id=int(broadcaster_user_id),
event_type=event_type
),
task_queue=MAIN_QUEUE
task_queue=MAIN_QUEUE,
schedule_to_close_timeout=timedelta(minutes=1)
)