from funky import (
AssistantMessageEvent,
TextContentBlock,
TurnCompletedEvent,
TurnFailedEvent,
)
submission = funky.sessions.send_message(
session.id,
content="Inspect the repository and identify the root cause.",
)
with funky.sessions.stream_events(
session.id,
after_seq=submission.seq,
) as stream:
for event in stream:
if isinstance(event, AssistantMessageEvent):
for block in event.payload.content:
if isinstance(block, TextContentBlock):
print(block.text, end="", flush=True)
elif isinstance(event, TurnCompletedEvent):
print()
break
elif isinstance(event, TurnFailedEvent):
raise RuntimeError(event.payload.message)