Compare commits

..

8 Commits

Author SHA1 Message Date
1c5b7e81e8 Migrate to python 3.12 2025-04-22 01:51:36 +02:00
586359f8ce Fix 2025-04-22 01:32:12 +02:00
12dd0f9af7 Fix 2025-04-22 01:22:37 +02:00
4174d67084 Fix 2025-04-22 01:17:42 +02:00
2d8b767ae3 Revert to python 3.13 2025-04-22 00:56:38 +02:00
a0a53800ab Migrate to python3.11 2025-04-22 00:51:14 +02:00
959ab30265 Revert "Fix"
This reverts commit 560a5ac793.
2025-04-22 00:49:53 +02:00
560a5ac793 Fix 2025-04-22 00:42:21 +02:00
5 changed files with 10 additions and 2 deletions

View File

@@ -1,4 +1,4 @@
FROM ghcr.io/astral-sh/uv:python3.13-bookworm-slim
FROM ghcr.io/astral-sh/uv:python3.12-bookworm-slim
WORKDIR /app
COPY ./pyproject.toml ./uv.lock ./

View File

@@ -11,4 +11,8 @@ async def syncronize(twitch_id: int):
if streamer.integrations.discord is None:
return
await syncronize_internal(streamer.twitch, streamer.integrations.discord.guild_id)
try:
await syncronize_internal(streamer.twitch, streamer.integrations.discord.guild_id)
except Exception as e:
activity.logger.error(f"Error during synchronization: {e}")
raise e

View File

@@ -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),
)

View File

@@ -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)
)

View File

@@ -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)
)