async def METHOD_NAME(self, finish: AgentFinish, **kwargs: Any) -> Any:
    """Run on agent end."""
    resp = ChatResponse(
        message="",
        type="stream",
        intermediate_steps=finish.log,
    )
    await self.websocket.send_json(resp.dict())