diff --git a/src/applications/twitch_webhook/activities/on_state_change.py b/src/applications/twitch_webhook/activities/on_state_change.py
index abdada9..45f8702 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: str
+    streamer_id: int
     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(
-        int(data.streamer_id),
+        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 9bcf705..6575c17 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=str(broadcaster_user_id),
+                streamer_id=int(broadcaster_user_id),
                 event_type=event_type
             ),
             task_queue=MAIN_QUEUE,