angee.workflows_agents.sessions

Session lifecycle service binding persisted agent chat to workflows.

start_session

def start_session(agent: Any, *, owner: Any, context: dict[str, Any]) -> Any

Create a persisted session and start its seeded workflow run.

post_message

def post_message(session: Any, text: str) -> Any

Append one pending turn and deliver it to the session workflow.

close_session

def close_session(session: Any) -> Any

Close a persisted session, expire approvals, and wake its workflow.

close_agent_sessions

def close_agent_sessions(agent: Any) -> None

Close every open persisted session through the lifecycle service.

run_for

def run_for(session: Any) -> Any

Return the one workflow run whose generic subject is session.