import json
import time
 
def emit_json_trace(state):
    trace = {
        "task_id": state.task_id,
        "status": state.corridor_status,
        "steps": [],
        "q_history": []
    }
 
    for i, step in enumerate(state.steps):
        trace["steps"].append({
            "step_id": step.step_id,
            "parent_step_id": step.parent_step_id,
            "action": step.action,
            "observation": step.observation,
            "q_metrics": step.q_metrics,
            "timestamp": getattr(step, "timestamp", None)
        })
 
    for i, q in enumerate(state.q_history):
        trace["q_history"].append({
            "step": i,
            **q
        })
 
    return json.dumps(trace, indent=2)

import time
 
def agent_step(self, state):
    step_id = len(state.steps)
    parent = step_id - 1 if step_id > 0 else None
 
    last_obs = state.steps[-1].observation if state.steps else "START"
    action = self.llm(f"Task: {state.task_id}\nLast: {last_obs}\nNext action.")
    observation = f"Executed: {action}"
 
    state.steps.append(
        CorridorStep(
            step_id=step_id,
            parent_step_id=parent,
            action=action,
            observation=observation,
            q_metrics={},
            timestamp=time.time()
        )
    )
    return state

final_state = app.invoke(initial_state, config={...})
json_trace = emit_json_trace(final_state)
 
with open("corridor_trace.json", "w") as f:
    f.write(json_trace)