From df501c27d714041e330d68b7b80b6d5c98e67747 Mon Sep 17 00:00:00 2001 From: Bulat Kurbanov Date: Tue, 22 Apr 2025 18:30:14 +0200 Subject: [PATCH] Fix --- src/applications/twitch_webhook/activities/on_state_change.py | 4 ++-- src/applications/twitch_webhook/workflows/on_stream_online.py | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/src/applications/twitch_webhook/activities/on_state_change.py b/src/applications/twitch_webhook/activities/on_state_change.py index 45f8702..abdada9 100644 --- a/src/applications/twitch_webhook/activities/on_state_change.py +++ b/src/applications/twitch_webhook/activities/on_state_change.py @@ -7,7 +7,7 @@ from applications.twitch_webhook.watcher import StateWatcher class OnStreamStateChangeActivity(BaseModel): - streamer_id: int + streamer_id: str event_type: EventType new_state: State | None = None @@ -17,7 +17,7 @@ async def on_stream_state_change_activity( data: OnStreamStateChangeActivity ): await StateWatcher.on_stream_state_change( - data.streamer_id, + int(data.streamer_id), data.event_type, data.new_state, ) diff --git a/src/applications/twitch_webhook/workflows/on_stream_online.py b/src/applications/twitch_webhook/workflows/on_stream_online.py index 6575c17..9bcf705 100644 --- a/src/applications/twitch_webhook/workflows/on_stream_online.py +++ b/src/applications/twitch_webhook/workflows/on_stream_online.py @@ -14,7 +14,7 @@ class OnStreamOnlineWorkflow: await workflow.start_activity( on_stream_state_change_activity, OnStreamStateChangeActivity( - streamer_id=int(broadcaster_user_id), + streamer_id=str(broadcaster_user_id), event_type=event_type ), task_queue=MAIN_QUEUE,