This commit is contained in:
2025-04-22 18:30:14 +02:00
parent 33fbc4c446
commit df501c27d7
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):
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,
)

View File

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