def plan(state: State): writer = get_stream_writer() writer({"stage": "plan", "detail": f"Outline ready for {state['topic']}"}) return {"outline": f"Define, stream, verify {state['topic']}"} def draft(state: State): return {"result": f"Completed: {state['outline']}"}