Function _remove_context

helpers/parallel_tools.py:576–589

(context_id: str | None)

async def _remove_context(context_id: str | None) -> None:
    if not context_id:
        return
    from agent import AgentContext
    from helpers import persist_chat

    context = AgentContext.get(context_id)
    if context:
        try:
            context.reset()
        except Exception:
            pass
        AgentContext.remove(context_id)
    persist_chat.remove_chat(context_id)


def _log_parallel_child_started(agent: "Agent", job: ParallelJob) -> None: