Skip to content
Closed
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
The table of contents is too big for display.
Diff view
Diff view
  •  
  •  
  •  
Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,7 @@
import time

from agent_comms.child_process import BoundedRun, ProcessIdentity
from agent_comms.field_codec import FieldCodec
from agent_comms.nominal.field_codec import FieldCodec


def digest(path):
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,7 @@
import time

from agent_comms.child_process import BoundedRun, ProcessIdentity
from agent_comms.field_codec import FieldCodec
from agent_comms.nominal.field_codec import FieldCodec


def digest(path):
Expand Down
2 changes: 1 addition & 1 deletion src/agent_comms/acp.py
Original file line number Diff line number Diff line change
Expand Up @@ -79,7 +79,7 @@
from .coordination_database import CoordinationStore
from .cursor_owner import CursorOwner
from .cursor_publication import CursorPublication
from .field_codec import ClaimId, FieldCodec, MalformedRecord, RootId
from .nominal.field_codec import ClaimId, FieldCodec, MalformedRecord, RootId
from .image_inputs import prompt_images
from .input_drain import InputDrain
from .config_options import ConfigOptions
Expand Down
4 changes: 2 additions & 2 deletions src/agent_comms/acp_extension.py
Original file line number Diff line number Diff line change
Expand Up @@ -26,9 +26,9 @@
from .agent_events import CompactionEvent
from .child_process import ProcessIdentity
from .context_reading import ContextReading
from .declared_family import DeclaredFamily
from .nominal.declared_family import DeclaredFamily
from .external_transcript import DraftRow
from .field_codec import (
from .nominal.field_codec import (
AssignmentId,
ClaimId,
AcceptsNull,
Expand Down
4 changes: 2 additions & 2 deletions src/agent_comms/acp_failure.py
Original file line number Diff line number Diff line change
Expand Up @@ -22,9 +22,9 @@
from .turn_input_source import OriginalTurnInput

from .coordination_errors import Refused
from .declared_family import DeclaredFamily, UnknownFamilyMember
from .nominal.declared_family import DeclaredFamily, UnknownFamilyMember
from .delivery_presentation import DeliveryPresentation
from .field_codec import (
from .nominal.field_codec import (
FieldCodec, JsonShapeFamily, JsonShapeMember, NullMember, RecordMember, SubclassUnion,
WireName, WireOmitDefault, boundary_decoder,
)
Expand Down
4 changes: 2 additions & 2 deletions src/agent_comms/active_route.py
Original file line number Diff line number Diff line change
Expand Up @@ -18,9 +18,9 @@

from .bus import Bus
from .child_process import Platform
from .declared_family import DeclaredFamily
from .nominal.declared_family import DeclaredFamily
from .errors import RelationViolationError
from .field_codec import FieldCodec, MalformedRecord, PathText, ScratchName
from .nominal.field_codec import FieldCodec, MalformedRecord, PathText, ScratchName
from .launch_root import LaunchRoot
from .locked_store import DocumentBytes
from .private_nk_entrypoint import PrivateNkLaunch, RootLaunch
Expand Down
4 changes: 2 additions & 2 deletions src/agent_comms/activity.py
Original file line number Diff line number Diff line change
Expand Up @@ -13,9 +13,9 @@
from typing import TYPE_CHECKING, ClassVar, Self, Annotated


from .declared_family import DeclaredFamily
from .nominal.declared_family import DeclaredFamily
from .errors import RelationViolationError
from .field_codec import (
from .nominal.field_codec import (
FieldCodec,
NullMember,
projected,
Expand Down
2 changes: 1 addition & 1 deletion src/agent_comms/activity_clocks.py
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@
from dataclasses import dataclass, field, fields
from typing import TYPE_CHECKING, Self

from .field_codec import FieldCodec
from .nominal.field_codec import FieldCodec
from .projection_source import ProducedRow, ProjectionSource
from .typed_table import TypedRow

Expand Down
4 changes: 2 additions & 2 deletions src/agent_comms/agent_activity.py
Original file line number Diff line number Diff line change
Expand Up @@ -34,9 +34,9 @@
)
from .audience_manifest import FrozenRecipient
from .coordinator import Coordination
from .declared_family import DeclaredFamily
from .nominal.declared_family import DeclaredFamily
from .errors import RelationViolationError
from .field_codec import ThreadLookup, TurnId
from .nominal.field_codec import ThreadLookup, TurnId
from .routing import NoTurnRouting, Routing
from .runtime_info import RuntimeInfo, RuntimeInfoStore
from .thread_identity import OwnerIdentity, ThreadIncarnation
Expand Down
4 changes: 2 additions & 2 deletions src/agent_comms/agent_backend.py
Original file line number Diff line number Diff line change
Expand Up @@ -25,8 +25,8 @@
from types import MappingProxyType
from typing import TYPE_CHECKING, ClassVar, Self

from .declared_family import DeclaredFamily
from .field_codec import InputId
from .nominal.declared_family import DeclaredFamily
from .nominal.field_codec import InputId
from .image_input import ImageInput
from .pi_counts import PiCount
from .pi_vocabulary import CompactionReason, ThinkingLevelField
Expand Down
2 changes: 1 addition & 1 deletion src/agent_comms/agent_event_updates.py
Original file line number Diff line number Diff line change
Expand Up @@ -35,7 +35,7 @@
)
from .context_reading import ContextUsage, UnsizedContext
from .coordinator import Coordination
from .field_codec import TurnId
from .nominal.field_codec import TurnId
from .tool_declaration import (
EditAction,
ExecuteAction,
Expand Down
4 changes: 2 additions & 2 deletions src/agent_comms/agent_events.py
Original file line number Diff line number Diff line change
Expand Up @@ -27,8 +27,8 @@
)
from .child_process import ProcessIdentity
from .coordinator import Coordination
from .declared_family import DeclaredFamily
from .field_codec import (
from .nominal.declared_family import DeclaredFamily
from .nominal.field_codec import (
InputId,
NullMember,
ToolCallId,
Expand Down
2 changes: 1 addition & 1 deletion src/agent_comms/agent_inbox.py
Original file line number Diff line number Diff line change
Expand Up @@ -16,7 +16,7 @@
from .coordination_database import CoordinationStore
from .coordination_tables.assignments import WakeAssignment
from .coordination_tables.harness_deliveries import HarnessDelivery
from .field_codec import RecordMember
from .nominal.field_codec import RecordMember
from .message_reference import AfterMessageStart, InboxStart, MessageReference, StreamBeginning
from .read_basis import ReadCursor

Expand Down
2 changes: 1 addition & 1 deletion src/agent_comms/annotation_disclosure.py
Original file line number Diff line number Diff line change
Expand Up @@ -7,7 +7,7 @@
from dataclasses import dataclass
from typing import TYPE_CHECKING, ClassVar

from .declared_family import DeclaredFamily
from .nominal.declared_family import DeclaredFamily

if TYPE_CHECKING:
from .turn_context import ContextSpan
Expand Down
2 changes: 1 addition & 1 deletion src/agent_comms/assignment_states.py
Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,7 @@

from .coordination_errors import IdentityConflict, IntegrityViolationError
from .coordinator_vocabulary import CoordinatorVocabulary
from .field_codec import AssignmentId, FieldCodec, ThreadLookup
from .nominal.field_codec import AssignmentId, FieldCodec, ThreadLookup
from .lifecycle import LifecycleState
from .lifecycle_capability import Active, Complete, Deferred, Failed, Pending, Terminal
from .notification_progress import (
Expand Down
2 changes: 1 addition & 1 deletion src/agent_comms/assignment_store.py
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,7 @@

import sqlite3

from agent_comms.field_codec import AssignmentId, ThreadLookup
from agent_comms.nominal.field_codec import AssignmentId, ThreadLookup

from collections.abc import Callable, Sequence
from dataclasses import replace
Expand Down
2 changes: 1 addition & 1 deletion src/agent_comms/attempt_recovery.py
Original file line number Diff line number Diff line change
Expand Up @@ -57,7 +57,7 @@
from .private_send_stage import TriageNativeSend
from .lifecycle_capability import Deferred
from agent_comms.typed_table import RowNotFoundError
from .field_codec import MalformedRecord, ScratchName, ThreadLookup
from .nominal.field_codec import MalformedRecord, ScratchName, ThreadLookup
from .input_disposition import InputDispositions
from .locked_store import RegistryFile
from .registration import Registration
Expand Down
4 changes: 2 additions & 2 deletions src/agent_comms/attempt_resolution.py
Original file line number Diff line number Diff line change
Expand Up @@ -4,8 +4,8 @@

from dataclasses import dataclass

from .declared_family import DeclaredFamily
from .field_codec import MessageId, NullMember, OrderId, RetryDecisionId, SubclassUnion, TaggedRecordMember, TurnId
from .nominal.declared_family import DeclaredFamily
from .nominal.field_codec import MessageId, NullMember, OrderId, RetryDecisionId, SubclassUnion, TaggedRecordMember, TurnId


class WorkDecision(DeclaredFamily, affix="Decision"):
Expand Down
2 changes: 1 addition & 1 deletion src/agent_comms/audience_manifest.py
Original file line number Diff line number Diff line change
Expand Up @@ -25,7 +25,7 @@
from agent_comms.coordination_contracts import MAX_IDENTIFIER_CHARS

from .channel_targets import exact_stored_target
from .field_codec import FieldCodec, MalformedRecord, ThreadLookup
from .nominal.field_codec import FieldCodec, MalformedRecord, ThreadLookup
from .messages import BusCapability, CarriesEnvelope, Message
from .projection_source import ProducedRow, ProjectionSource

Expand Down
2 changes: 1 addition & 1 deletion src/agent_comms/backend.py
Original file line number Diff line number Diff line change
Expand Up @@ -49,7 +49,7 @@
from .agent_backend import NO_INPUT_START_LISTENER, InputStartListener, TurnInbox
from .coordinator import Coordination
from .extension_ui import ExtensionUiSession
from .field_codec import InputId, MalformedRecord, boundary_decoder
from .nominal.field_codec import InputId, MalformedRecord, boundary_decoder
from .image_input import ImageInput
from .native_attestation import AttestationError
from .native_child import PiSessionChild
Expand Down
2 changes: 1 addition & 1 deletion src/agent_comms/behaviour_patterns.py
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@

from .child_process import CountPrinted, NoIntegerPrinted
from .commander.order import CheckRequest
from .declared_family import DeclaredFamily
from .nominal.declared_family import DeclaredFamily
from .pattern_sources import (
CeremonyFailure,
CommanderRule,
Expand Down
4 changes: 2 additions & 2 deletions src/agent_comms/build_identity.py
Original file line number Diff line number Diff line change
Expand Up @@ -7,8 +7,8 @@
from pathlib import Path
from typing import TYPE_CHECKING, Annotated, ClassVar

from agent_comms.declared_family import DeclaredFamily
from agent_comms.field_codec import GitCommitText
from agent_comms.nominal.declared_family import DeclaredFamily
from agent_comms.nominal.field_codec import GitCommitText
from agent_comms.installer.runtime_resolution import RuntimePackage, RuntimeResolution
from agent_comms.launch_runtime import LaunchRuntime
from agent_comms.repo import Repo
Expand Down
2 changes: 1 addition & 1 deletion src/agent_comms/bus.py
Original file line number Diff line number Diff line change
Expand Up @@ -47,7 +47,7 @@
ResourceClaim,
)
from agent_comms.errors import CommittedMessageError, RelationViolationError, UnclaimedError
from agent_comms.field_codec import ClaimId, FieldCodec, MessageId, ThreadLookup
from agent_comms.nominal.field_codec import ClaimId, FieldCodec, MessageId, ThreadLookup
from agent_comms.locked_store import BusFile, FileStore, SQLiteFile, StoreCommittedError
from agent_comms.message_reference import MessageReference
from agent_comms.private_path import FileIdentity, PresentPath
Expand Down
2 changes: 1 addition & 1 deletion src/agent_comms/bus_publication.py
Original file line number Diff line number Diff line change
Expand Up @@ -29,7 +29,7 @@
)
from agent_comms.typed_table import Column, Generated, sql_literal

from .field_codec import FieldCodec, MessageId, ThreadLookup
from .nominal.field_codec import FieldCodec, MessageId, ThreadLookup
from .repo import Checkout
from .read_basis import RepliesDisplayScope
from .wake_policy import RecipientDecision
Expand Down
2 changes: 1 addition & 1 deletion src/agent_comms/bus_route_counts.py
Original file line number Diff line number Diff line change
Expand Up @@ -7,7 +7,7 @@

from .bus_tables import ReceivedSource
from .class_fact import ClassFact
from .field_codec import ThreadLookup
from .nominal.field_codec import ThreadLookup
from .messages import BusProjectionTables, BusRow, MessageInput, PublicRecord, PublicSender
from .projection_source import ProducedRow
from .read_basis import ReadCursor
Expand Down
2 changes: 1 addition & 1 deletion src/agent_comms/bus_source_page.py
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@
from typing import Self

from .coordination_errors import IdentityConflict
from .field_codec import FieldCodec, ThreadLookup
from .nominal.field_codec import FieldCodec, ThreadLookup


@dataclass(frozen=True, kw_only=True)
Expand Down
2 changes: 1 addition & 1 deletion src/agent_comms/bus_tables.py
Original file line number Diff line number Diff line change
Expand Up @@ -10,7 +10,7 @@

from agent_comms import messages
from agent_comms.errors import RelationViolationError
from agent_comms.field_codec import FieldCodec, ThreadLookup
from agent_comms.nominal.field_codec import FieldCodec, ThreadLookup
from agent_comms.message_reference import MessageReference
from agent_comms.typed_table import (
Column,
Expand Down
4 changes: 2 additions & 2 deletions src/agent_comms/change_report.py
Original file line number Diff line number Diff line change
Expand Up @@ -19,8 +19,8 @@

from agent_comms.errors import MissingSourceLine

from .declared_family import DeclaredFamily
from .field_codec import (
from .nominal.declared_family import DeclaredFamily
from .nominal.field_codec import (
MalformedRecord,
NullMember,
RecordMember,
Expand Down
2 changes: 1 addition & 1 deletion src/agent_comms/channel_coding_tools.py
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,7 @@
FileClaimPath,
WakeClaim,
)
from .field_codec import ClaimId, FieldCodec, InputId, MalformedRecord
from .nominal.field_codec import ClaimId, FieldCodec, InputId, MalformedRecord
from .lifecycle_capability import Executing
from .native_arguments import NativeArguments
from .native_runtime_input import NativeRuntimeInput
Expand Down
2 changes: 1 addition & 1 deletion src/agent_comms/channel_management.py
Original file line number Diff line number Diff line change
Expand Up @@ -14,7 +14,7 @@
from .channel_targets import ChannelTarget, Tag
from .channels import Channel, SavedView
from .cli_result import CliResult
from .declared_family import DeclaredFamily
from .nominal.declared_family import DeclaredFamily
from .display_order import ChannelSort, ThreadSort
from .message_bus import MessageBus
from .messages import InfoKind, MembershipConversationRole, Message
Expand Down
4 changes: 2 additions & 2 deletions src/agent_comms/channel_targets.py
Original file line number Diff line number Diff line change
Expand Up @@ -8,9 +8,9 @@

from .activity_clocks import ActivityClocks
from .class_fact import ClassFact
from .declared_family import DeclaredFamily
from .nominal.declared_family import DeclaredFamily
from .errors import HumanSendRefusedError, RelationViolationError, UnregisteredThreadError
from .field_codec import NullMember, SingleFieldValue, SubclassUnion
from .nominal.field_codec import NullMember, SingleFieldValue, SubclassUnion
from .history_result import DmHistoryPageResult, HistoryPageResult
from .projection_source import ProducedRow, ProjectionSource
from .repo import Checkout
Expand Down
4 changes: 2 additions & 2 deletions src/agent_comms/channels.py
Original file line number Diff line number Diff line change
Expand Up @@ -13,10 +13,10 @@
from .projection_source import ProjectionSource
from .channel_targets import ChannelTarget, Tag
from .cli_result import CliResult
from .declared_family import DeclaredFamily
from .nominal.declared_family import DeclaredFamily
from .display_order import CreatedThreadSort, ThreadSort
from .errors import RelationViolationError
from .field_codec import FieldCodec, CatalogExclude
from .nominal.field_codec import FieldCodec, CatalogExclude
from .history_result import ChannelHistoryPageResult, EverythingHistoryPageResult, HistoryPageResult
from .messages import MembershipTransition
from .read_basis import AllChannelDisplayScope, ChannelDisplayScope, MemberActivityDisplayScope
Expand Down
6 changes: 3 additions & 3 deletions src/agent_comms/child_process.py
Original file line number Diff line number Diff line change
Expand Up @@ -41,11 +41,11 @@
from tempfile import TemporaryDirectory
from typing import TYPE_CHECKING, Annotated, Any, BinaryIO, ClassVar, NoReturn, Self, TextIO

from .declared_family import DeclaredFamily
from .nominal.declared_family import DeclaredFamily
from .errors import RelationViolationError
from .field_codec import FieldCodec, FieldDirective, Id128, NullMember, RecordMember, SubclassUnion, WireRequired
from .nominal.field_codec import FieldCodec, FieldDirective, Id128, NullMember, RecordMember, SubclassUnion, WireRequired
from .launch_runtime import INHERITED_ENVIRONMENT, LaunchRuntime, RestoredRuntime
from .sealed import Sealed
from .nominal.sealed import Sealed
from .systemd_unit import AgentsSlice, SystemdUnit

if TYPE_CHECKING:
Expand Down
2 changes: 1 addition & 1 deletion src/agent_comms/cli_bridges/claude_protocol.py
Original file line number Diff line number Diff line change
Expand Up @@ -27,7 +27,7 @@
TimestampedWire,
WireHeader,
)
from agent_comms.field_codec import (
from agent_comms.nominal.field_codec import (
FieldCodec,
MalformedRecord,
MessageId,
Expand Down
2 changes: 1 addition & 1 deletion src/agent_comms/cli_bridges/codex_connection.py
Original file line number Diff line number Diff line change
Expand Up @@ -10,7 +10,7 @@
import aiohttp
from pydantic import JsonValue

from agent_comms.field_codec import FieldCodec
from agent_comms.nominal.field_codec import FieldCodec
from .codex_protocol import (
Capabilities, ClientInfo, Initialize, InitializeResponse, Initialized, Request,
RPC_RESPONSE, RateLimits, RateLimitsResponse, ReadRateLimits, RequestParams, RpcNotification, RpcReply,
Expand Down
4 changes: 2 additions & 2 deletions src/agent_comms/cli_bridges/codex_protocol.py
Original file line number Diff line number Diff line change
Expand Up @@ -20,9 +20,9 @@
)

from agent_comms.cli_protocol import Declared, TaggedWire, TextWire
from agent_comms.declared_family import UnknownFamilyMember
from agent_comms.nominal.declared_family import UnknownFamilyMember
from agent_comms.external_transcript import EarlierPage, NoEarlierPage
from agent_comms.field_codec import (
from agent_comms.nominal.field_codec import (
FieldCodec,
MessageId,
ToolCallId,
Expand Down
2 changes: 1 addition & 1 deletion src/agent_comms/cli_bridges/codex_rollout.py
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,7 @@
)

from agent_comms.cli_protocol import Declared, OpenWire, TimestampedWire, WireHeader
from agent_comms.field_codec import ToolCallId
from agent_comms.nominal.field_codec import ToolCallId
from agent_comms.runtime_updates import (
HiddenItem,
HistoryNotice,
Expand Down
2 changes: 1 addition & 1 deletion src/agent_comms/cli_bridges/history.py
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,7 @@
from pydantic import TypeAdapter

from agent_comms.agent_runtime import ReadsHistory
from agent_comms.field_codec import SubclassUnion
from agent_comms.nominal.field_codec import SubclassUnion
from agent_comms.harness_install import (
ClaudeCodeHarness, CodexHarness, Harness, HarnessSession, OpenCodeHarness, PiHarness,
)
Expand Down
4 changes: 2 additions & 2 deletions src/agent_comms/cli_bridges/monitor.py
Original file line number Diff line number Diff line change
Expand Up @@ -19,9 +19,9 @@

from agent_comms.child_process import ProcessIdentity
from agent_comms.harness_delivery_states import Outcome
from agent_comms.declared_family import DeclaredFamily
from agent_comms.nominal.declared_family import DeclaredFamily
from agent_comms.installer.runtime_wire import CrossesRuntimes
from agent_comms.field_codec import FieldCodec, MalformedRecord, MessageId, PathText
from agent_comms.nominal.field_codec import FieldCodec, MalformedRecord, MessageId, PathText
from agent_comms.launch_runtime import LaunchRuntime
from agent_comms.messages import Message
from agent_comms.thread_status import ConnectedThreadStatus, PausedBridgeThreadStatus
Expand Down
Loading
Loading