세션은 이어 가고 JSONL은 다시 세울 근거를 남겨

import dataclasses, json, pathlib
from claude_agent_sdk import ClaudeAgentOptions, ClaudeSDKClient

def to_record(message) -> dict:
    # SDK 메시지는 dataclass야(.dict()는 없어). asdict()가 안쪽 블록까지 따라가.
    return {"type": type(message).__name__, **dataclasses.asdict(message)}

async def run_with_jsonl(conv_id: str, prompt: str, forward_to_user):
    log_path = pathlib.Path(f"/var/lib/myagent/sessions/{conv_id}.jsonl")
    log_path.parent.mkdir(parents=True, exist_ok=True)
    options = ClaudeAgentOptions(cwd="/srv", include_partial_messages=True)  # 델타는 StreamEvent로 와
    with log_path.open("a", buffering=1) as log:  # line-buffered
        async with ClaudeSDKClient(options=options) as client:
            await client.query(prompt)
            async for message in client.receive_response():
                log.write(json.dumps(to_record(message), default=str) + "\n")
                log.flush()  # write before show
                forward_to_user(message)

from claude_agent_sdk import ClaudeAgentOptions, ClaudeSDKClient

# ResultMessage(그리고 스트림으로 온 메시지)마다 CLI 세션 id가 실려 와.
# 대화 옆에 저장해 둬. 여기선 지난 턴 결과에서 꺼냈어.
session_id = last_result.session_id

options = ClaudeAgentOptions(cwd="/srv", resume=session_id)  # CLI가 그 세션을 다시 불러와
async with ClaudeSDKClient(options=options) as client:
    await client.query("Continue where we left off.")
    async for message in client.receive_response():
        print(message)