trace-mind 1.0.4

TraceMind smart agent runtime and tooling

TraceMind — AI MAPE-K Autonomous Agent Framework

TraceMind is a lightweight, event-sourced autonomous agent runtime that follows the MAPE-K loop: Monitor → Analyze → Plan → Execute over shared Knowledge.

• Event-Sourced Core — every state change is an append-only fact (auditable by design).
• Static Flow Engine — declarative flows (YAML/JSON) exportable to DOT/JSON for graphs.
• Policy via MCP — select/update arms locally or over JSON-RPC with timeout & safe fallback.
• Smart Layer — summarize / diagnose / plan / reflect with trace-linked spans.
• Ops-Ready — REST /api/*, Prometheus /metrics, health /healthz /readyz.

---

Agent Evolution Timeline ───────────────────────────────────────────── (1) Client + Server (2) Digital Twin (3) Autonomous Agent ─────────────── ─────────────── ──────────────────── • Proxy / Adapter • Mirror of entity • Observer • Sip, Websocket • Present + feedback • Executor • Hide protocol • IoT, Telecom • Collaborator complexity • State visualization • AI-driven autonomy • Simulation / feedback • Coordination in MAS

Value: simplify access Value: insight + control Value: autonomy + learning

---

✨ Features

• Event Sourcing Core: append-only event store powered by the Binary Segment Log (tm/storage/binlog.py). JSONL and SQLite remain optional adapters planned for future expansion.

• DDD Structure: clear separation of domain, application, and infrastructure layers.

• Pipeline Engine: field-driven processing (Plan → Rule → Step), statically analyzable.

• Tracing & Reflection: every step produces auditable spans.

• Smart Layer:

  • Summarize: human-readable summaries of recent events.
  • Diagnose: heuristic anomaly detection with suggested actions.
  • Plan: goal → steps → optional execution.
  • Reflect: postmortem reports and threshold recommendations.

• Visualization:

  • Static: export DOT/JSON diagrams of flows.
  • Dynamic: SSE dashboard with live DAG and insights panel.

• Protocols:

  • MCP (Model Context Protocol) integration (JSON-RPC 2.0) – see the latest specification and the community GitHub org. Example flow recipe:

    from tm.recipes.mcp_flows import mcp_tool_call
    
    spec = mcp_tool_call("files", "list", ["path"])
    runtime.register(_SpecFlow(spec))
    

• Interfaces:

  • REST API: /api/commands/*, /api/query/*, /agent/chat.
  • Metrics: /metrics (Prometheus format).
  • Health checks: /healthz, /readyz.

---

📂 Architecture (ASCII Overview)

                +----------------+
                |   REST / CLI   |
                +----------------+
                         |
                    [Commands]
                         v
                +----------------+
                |  App Service   |
                +----------------+
                         |
                  +------+------+
                  |             |
             [Event Store]   [Event Bus]
                  |             |
          +-------+        +----+-----------------+
          |                |                      |
     [Projections]   [Pipeline Engine]      [Smart Layer]
                          |              (Summarize/Diagnose/Plan/Reflect)
                          v
                      [Trace Store]

---

📚 Documentation

• Flow & policy recipes
• Helpers reference
• Policy lifecycle & MCP integration
• Storage configuration
• Validation & simulation workflows

Scale & Reliability

• Scale & Reliability guide
• Queue retries & DLQ

Safety & Governance

• Governance overview
• Guardrails
• Human approvals

---

🚀 Quick Start

# Install (use venv if you like)
pip install -U "git+https://github.com/RaphaelYu/TraceMind.git@v1.0.4"

# Version & pipeline health
tm --version
tm pipeline analyze

# Scaffold & run a minimal flow
tm init demo
cd demo
tm run flows/hello.yaml -i '{"name":"world"}'

# Validate and export the flow graph
mkdir -p out
tm pipeline export-dot --out-rules-steps out/rules.dot --out-step-deps out/steps.dot

# Policy: list / verify / (optional) update
python3 - <<'PY'
import asyncio
from tm.policy.adapter import PolicyAdapter
from tm.policy.local_store import LocalPolicyStore


async def main():
    arms = {
        "maint.default": {"threshold": 0.72},
        "maint.backup": {"threshold": 0.6},
    }
    store = LocalPolicyStore(arms=arms)
    adapter = PolicyAdapter(mcp=None, local=store)
    print("arms:", await adapter.list_arms())
    baseline = await adapter.get("maint.default")
    print("before:", baseline)
    updated = await adapter.update("maint.default", {"threshold": 0.85})
    print("after:", updated)


asyncio.run(main())
PY

Always-on Agent quickstart

Reuse the copy/paste examples in the validation guide to keep agents continuously self-checking:

• docs/validation.md — tm flow lint, tm flow plan, tm validate, tm simulate.
• scripts/validate_examples.sh — end-to-end smoke test that runs as part of CI.

Need to configure persistence for production? See docs/storage.md for KStore URLs and fallback behaviour.

Run in container

docker build -t trace-mind ./docker

docker run --rm -it \
  --read-only \
  -v $(pwd)/data:/data \
  -p 8080:8080 \
  trace-mind

Scale & Reliability demo

See the Scale & Reliability guide for full context. The commands below can be pasted into a shell to exercise the worker pool, queue stats, and DLQ tooling.

# Start workers
TM_LOG=info tm workers start -n 4 --queue file --lease-ms 30000 &

# Enqueue 1000 CPU-light tasks
for i in {1..1000}; do tm enqueue flows/hello.yaml -i '{"name":"w'$i'"}'; done

# Live queue stats
tm queue stats

# Retry/DLQ demo — simulate failures by input flag/env within your step
export FAIL_RATE=0.05
# (run some tasks…)

tm dlq ls | head        # Inspect
# Requeue a subset by id/prefix/predicate (implementation-specific)
tm dlq requeue <task-id>

# Graceful drain
tm workers stop

---

🧩 Roadmap

• More connectors (file bridge, http bridge, kafka bridge)
• Richer dashboard with interactive actions
• Adaptive thresholds in Reflector
• Optional LLM integration for natural summaries

---

📜 License

MIT (for personal and experimental use)

Quickstart: tm init demo --template minimal cd demo && tm run flows/hello.yaml -i '{"name":"world"}' More details: docs/quickstart.md