This commit is contained in:
2025-04-22 18:45:30 +02:00
parent df501c27d7
commit 90756c884c
2 changed files with 3 additions and 3 deletions

View File

@@ -7,7 +7,7 @@ from applications.twitch_webhook.watcher import StateWatcher
class OnStreamStateChangeActivity(BaseModel): class OnStreamStateChangeActivity(BaseModel):
streamer_id: str streamer_id: int
event_type: EventType event_type: EventType
new_state: State | None = None new_state: State | None = None
@@ -17,7 +17,7 @@ async def on_stream_state_change_activity(
data: OnStreamStateChangeActivity data: OnStreamStateChangeActivity
): ):
await StateWatcher.on_stream_state_change( await StateWatcher.on_stream_state_change(
int(data.streamer_id), data.streamer_id,
data.event_type, data.event_type,
data.new_state, data.new_state,
) )

View File

@@ -14,7 +14,7 @@ class OnStreamOnlineWorkflow:
await workflow.start_activity( await workflow.start_activity(
on_stream_state_change_activity, on_stream_state_change_activity,
OnStreamStateChangeActivity( OnStreamStateChangeActivity(
streamer_id=str(broadcaster_user_id), streamer_id=int(broadcaster_user_id),
event_type=event_type event_type=event_type
), ),
task_queue=MAIN_QUEUE, task_queue=MAIN_QUEUE,