distinct / distinct_protocol /__init__.py
aaxaxax's picture
initial commit
2aa8b3a
Raw History Blame Contribute Delete
2.09 kB
"""Versioned wire contracts shared by the Distinct server and workers."""
from .handshake import (
HANDSHAKE_VERSION,
Allowance,
HandshakeError,
OperatorApproval,
ResponseAuthentication,
ServerCatalogue,
SignedSnapshot,
parse_tool_ref,
)
from .models import (
MAX_LIVE_STEP_TEXT,
AGENT_MODES,
MAX_LIVE_STEPS_PER_JOB,
MAX_RUN_STEPS,
MODE_AGENT,
MODE_SIMPLE,
PHASE_CALLING_TOOL,
PHASE_DONE,
PHASE_FETCHING_WEIGHTS,
PHASE_GENERATING,
PHASE_GUARD_INPUT,
PHASE_GUARD_OUTPUT,
PHASE_LOADING_MODEL,
PHASE_OFFERED,
PHASE_PLANNING,
PHASE_QUEUED_ON_WORKER,
PHASE_WAITING_FOR_WORKER,
PHASE_WORKING,
PROTOCOL_VERSION,
RUN_PHASES,
STEP_KINDS,
STEP_MODEL,
STEP_PHASE,
STEP_TOOL_CALL,
STEP_TOOL_RESULT,
AgentCapabilities,
AgentSnapshot,
AgentStatus,
ChatMessage,
JobResult,
JobSpec,
JobStatus,
ModelManifest,
ProtocolError,
ToolSelection,
canonical_json,
normalise_phase,
utc_now,
)
__all__ = [
"HANDSHAKE_VERSION",
"AGENT_MODES",
"MAX_LIVE_STEPS_PER_JOB",
"MAX_RUN_STEPS",
"MODE_AGENT",
"MODE_SIMPLE",
"MAX_LIVE_STEP_TEXT",
"PHASE_CALLING_TOOL",
"PHASE_DONE",
"PHASE_FETCHING_WEIGHTS",
"PHASE_GENERATING",
"PHASE_GUARD_INPUT",
"PHASE_GUARD_OUTPUT",
"PHASE_LOADING_MODEL",
"PHASE_OFFERED",
"PHASE_PLANNING",
"PHASE_QUEUED_ON_WORKER",
"PHASE_WAITING_FOR_WORKER",
"PHASE_WORKING",
"PROTOCOL_VERSION",
"RUN_PHASES",
"STEP_KINDS",
"STEP_MODEL",
"STEP_PHASE",
"STEP_TOOL_CALL",
"STEP_TOOL_RESULT",
"AgentCapabilities",
"AgentSnapshot",
"AgentStatus",
"Allowance",
"ChatMessage",
"HandshakeError",
"JobResult",
"JobSpec",
"JobStatus",
"ModelManifest",
"OperatorApproval",
"ProtocolError",
"ResponseAuthentication",
"ServerCatalogue",
"SignedSnapshot",
"ToolSelection",
"canonical_json",
"normalise_phase",
"parse_tool_ref",
"utc_now",
]