agent/compression_automation.py

Rama main · réplica de lectura del repositorio original.

"""Carry automation at a compression boundary without opening worker storage."""


def carry_compression_automation(agent, old_session_id):
    # In-process state, not a sidecar: the bot-to-bot chain moves on every store (#137027).
    from agent.bot_chain import carry_chain
    carry_chain(old_session_id, agent.session_id)
    from agent.runtime_session_store import RuntimeSessionStore
    if isinstance(agent._session_db, RuntimeSessionStore):
        # The owner moved these exact sidecars atomically with child publication.
        return
    from agent.conversation_compression import _swallow
    with _swallow('Could not migrate goal on compression: %s'):
        from hermes_cli.goals import migrate_goal_to_session
        migrate_goal_to_session(old_session_id, agent.session_id, reason='compression')
    with _swallow('Could not migrate heartbeat on compression: %s'):
        from hermes_cli.heartbeat import migrate_heartbeat_to_session
        migrate_heartbeat_to_session(old_session_id, agent.session_id)
    with _swallow('Could not migrate loop on compression: %s'):
        from hermes_cli.loops import migrate_loop_to_session
        migrate_loop_to_session(old_session_id, agent.session_id, reason='compression')