Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@
import json
from typing import Any

from .control_plane.content_digest import BARE_SHA256_PATTERN
from ...control_plane.content_digest import BARE_SHA256_PATTERN


def page_chat_messages(session_id: str, messages: list[dict[str, Any]], *,
Expand Down
2 changes: 1 addition & 1 deletion loopx/capabilities/manager_context/roundtrip.py
Original file line number Diff line number Diff line change
Expand Up @@ -288,7 +288,7 @@ def project_chat_session_snapshot(root, store, session_id, *, registry,

snapshot = (store.session_snapshot(session_id, strict_messages=True) if message_limit is not None
else store.session_snapshot(session_id))
from ...chat_history import page_chat_messages
from .chat_history import page_chat_messages
page = (page_chat_messages(session_id, snapshot["messages"], limit=message_limit,
cursor=message_cursor) if message_limit is not None else None)
context_messages = snapshot["messages"]
Expand Down
2 changes: 1 addition & 1 deletion tests/architecture/test_content_digest_single_owner.py
Original file line number Diff line number Diff line change
Expand Up @@ -177,7 +177,7 @@
"loopx.capabilities.periodic_report.machine_defaults",
"loopx.capabilities.progress_review.receipt",
"loopx.chat_action_normalization",
"loopx.chat_history",
"loopx.capabilities.manager_context.chat_history",
"loopx.cli_commands.quota_capture",
"loopx.configuration_transaction",
"loopx.control_plane.agents.execution_facts",
Expand Down
6 changes: 3 additions & 3 deletions tests/test_chat_conversation_bindings.py
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@ def _history_page_brief():
"inputs": [], "acceptance": ["Return the original conclusion"], "return_requirement": "Return here"}


def test_history_page_keeps_one_original_collaboration_carrier(flow, monkeypatch):
def test_history_page_keeps_one_original_collaboration_carrier(flow, monkeypatch): # noqa: F811
from loopx.capabilities.manager_context.roundtrip import project_chat_session_snapshot

root, registry, store, create = flow
Expand All @@ -43,7 +43,7 @@ def observed(*args):
assert reads == [(sid, tid)]


def test_return_delivery_readback_survives_a_separate_history_page(flow):
def test_return_delivery_readback_survives_a_separate_history_page(flow): # noqa: F811
from loopx.capabilities.manager_context import acknowledge
from loopx.capabilities.manager_context.roundtrip import drain, report, project_chat_session_snapshot

Expand All @@ -68,7 +68,7 @@ def test_return_delivery_readback_survives_a_separate_history_page(flow):
assert sum(bool(row.get("collaboration")) for row in rows) == 1


def test_original_history_pages_freeze_append_boundary_and_keep_full_rows(ordinary, monkeypatch):
def test_original_history_pages_freeze_append_boundary_and_keep_full_rows(ordinary, monkeypatch): # noqa: F811
from urllib.parse import urlencode
from loopx.chat_server import ChatHTTPServer

Expand Down
2 changes: 1 addition & 1 deletion tests/test_chat_store_input_validation.py
Original file line number Diff line number Diff line change
Expand Up @@ -7,7 +7,7 @@

import loopx.chat_store as chat_store
from loopx.chat_store import CHAT_SESSION_SCHEMA_VERSION, ChatSessionStore
from loopx.chat_history import page_chat_messages
from loopx.capabilities.manager_context.chat_history import page_chat_messages


def test_agent_model_value_keeps_provider_protocol_characters() -> None:
Expand Down
Loading