mirror of
https://github.com/hanzoai/agent.git
synced 2026-09-11 21:08:51 +00:00
zeekay
ff7ef7114f
Consolidate all Hanzo agent infrastructure into one repo: - control-plane/: Go control plane server (was agents-new) - sdk/: Go, Python, TypeScript SDKs - deployments/: Docker, Kubernetes, Helm configs - Dockerfile.sdk: Python SDK image (ghcr.io/hanzoai/agent:latest) - CI builds both SDK + control-plane images No more agentfield — everything is hanzoai/agent.
71 lines
1.6 KiB
Python
71 lines
1.6 KiB
Python
"""Canonical execution status utilities for the Hanzo Agents SDK."""
|
|
|
|
from __future__ import annotations
|
|
|
|
from typing import Optional, Set, Tuple
|
|
|
|
CANONICAL_STATUSES: Tuple[str, ...] = (
|
|
"pending",
|
|
"queued",
|
|
"running",
|
|
"succeeded",
|
|
"failed",
|
|
"cancelled",
|
|
"timeout",
|
|
"unknown",
|
|
)
|
|
|
|
CANONICAL_STATUS_SET: Set[str] = set(CANONICAL_STATUSES)
|
|
|
|
_STATUS_ALIASES = {
|
|
"success": "succeeded",
|
|
"successful": "succeeded",
|
|
"completed": "succeeded",
|
|
"complete": "succeeded",
|
|
"done": "succeeded",
|
|
"ok": "succeeded",
|
|
"error": "failed",
|
|
"failure": "failed",
|
|
"errored": "failed",
|
|
"canceled": "cancelled",
|
|
"cancel": "cancelled",
|
|
"timed_out": "timeout",
|
|
"wait": "queued",
|
|
"waiting": "queued",
|
|
"in_progress": "running",
|
|
"processing": "running",
|
|
}
|
|
|
|
TERMINAL_STATUSES: Set[str] = {"succeeded", "failed", "cancelled", "timeout"}
|
|
|
|
|
|
def normalize_status(status: Optional[str]) -> str:
|
|
"""Return the canonical representation of a status string."""
|
|
|
|
if status is None:
|
|
return "unknown"
|
|
|
|
normalized = status.strip().lower()
|
|
if not normalized:
|
|
return "unknown"
|
|
|
|
if normalized in CANONICAL_STATUS_SET:
|
|
return normalized
|
|
|
|
return _STATUS_ALIASES.get(normalized, "unknown")
|
|
|
|
|
|
def is_terminal(status: Optional[str]) -> bool:
|
|
"""Return True if the provided status represents a terminal state."""
|
|
|
|
return normalize_status(status) in TERMINAL_STATUSES
|
|
|
|
|
|
__all__ = [
|
|
"CANONICAL_STATUSES",
|
|
"CANONICAL_STATUS_SET",
|
|
"TERMINAL_STATUSES",
|
|
"normalize_status",
|
|
"is_terminal",
|
|
]
|