NvAgent — Live DAG Monitor
NvAgent Observability

Live
Agent Brain Monitoring

Watch every orchestrated task — and every action it takes — execute in real time. Sub-agents, the skills they activate, and the MCP servers they call all recolor live as they start, finish, fail, or are skipped, so users see exactly what their AI is doing, not just the final answer.

What Is a DAG?

A Directed Acyclic Graph
is a Workflow's Blueprint

A directed acyclic graph (DAG) is a graph whose edges all point in one direction and that contains no cycles — once you leave a node by following the arrows, no sequence of edges can ever bring you back to it. That single property makes DAGs the natural language for representing dependencies.

DAGs are how modern systems describe the order things must happen in: compilers schedule code, build tools resolve dependencies, version-control systems track history, spreadsheets recalculate cells, and data pipelines plan their stages. Whenever "B can only run after A finishes" is the rule, a DAG is the right shape.

NvAgent uses the same shape. The orchestrator decomposes a complex request into tasks, declares the dependencies between them, and the resulting DAG becomes both the execution plan and the live picture you see on this page.

Source: Directed acyclic graph — Wikipedia

Plan A B C Done
Total Recall

Backed by a Full Historical Audit Database

The live graph is the tip of the iceberg. Behind it, PostgreSQL durably records every turn, every model call, and every action — a complete, replayable audit trail ready for any regulatory review.

Nothing the agent does is ephemeral. Every conversation turn, every LLM request and response, and every task action is written to the database the moment it happens — captured with the model used, token counts, cost, and precise start / stop timing. Long after a session ends you can reconstruct exactly what was asked, what the AI decided, which tools and skills it invoked, what it produced, and what it cost — turn by turn.

Conversation turns
Every user and assistant message, in sequence, tied to a session and user.
LLM requests & responses
The raw request and response JSON of every model call, stored verbatim.
Token usage & cost
Provider, model, and prompt / completion / total tokens for every single call.
Plans & tasks
The full task DAG — complexity, execution mode, dependencies and final response.
Sub-agent executions
Model, prompt, result, output files, errors, elapsed time and tokens per agent.
MCP tool calls
Every server and tool invoked, its arguments, status, errors and duration.
Skill activations
Which skill ran, the input it received, its status, errors and run time.
Evaluations
Per-task evaluator score, verdict and issues — the quality gate, on record.
Timing & structured logs
Start / stop timestamps, elapsed and run time, plus every log line tagged to its agent and task.
🏛️ Regulatory-ready. A defensible, timestamped record for audits, model-risk reviews and compliance requests.
Fully replayable. Reopen any past session and reconstruct the exact decision path, step by step.
💵 Cost accountability. Attribute every token and dollar to a user, session, plan, agent and model.
🔍 Root-cause ready. Verbatim request / response fidelity turns “why did it do that?” into a simple query.
Real-Time Status

Five Colors. One Source of Truth.

Every node in the graph carries one of five live states. The color updates the moment the orchestrator changes the task's status in PostgreSQL — no polling, no refresh button.

Pending
Waiting for predecessors to finish.
Running
A sub-agent is actively executing this task.
Done
Task completed successfully and feeds the next stage.
Error / Timeout
Task failed; the orchestrator decides whether to retry.
Skipped
Cascaded out because a dependency failed.
How We Built It

Postgres LISTEN/NOTIFY + SSE

The monitor uses what NvAgent already has — the orchestrator writes status to Postgres, Postgres pushes those changes to the API, and the API streams them to the browser. No queue, no broker, no extra service.

Phase 3
Orchestrator UPDATE
Postgres
pg_notify
FastAPI
SSE /events

A single pg_notify inside the same transaction that updates the task — under one millisecond on the user's request path.

Zero added latency

Each task state change is a single notify inside the existing UPDATE transaction. The orchestrator never blocks on a queue or a broker.

🧱

No new infrastructure

No Redis, no Kafka, no WebSocket gateway. Postgres and FastAPI are already in the stack — the monitor reuses both.

☸️

Kubernetes-native

Each pod opens its own LISTEN connection. Postgres delivers every notification to every replica, so the monitor scales horizontally with the API.

🛟

Back-pressure safe

The in-process fan-out uses bounded queues and drops the oldest event for slow clients, so a stuck browser tab cannot stall other consumers.

⏹️

Auto-shutdown

The SSE stream closes itself shortly after the plan reaches a terminal state — no orphan connections, no manual cleanup.

🔀

Future-proof contract

The same LISTEN/NOTIFY contract makes it trivial to extract the monitor into its own service later without changing a line of orchestrator code.

Side Panel

Every Task. Every Verdict. Every Dollar.

The monitor isn't just a graph — it's an audit trail. Alongside the live DAG, a side panel shows per-task progress and a cost summary so users know not just what the agent did, but how well and at what price.

  • Live status, model, and elapsed time per node
  • Evaluator verdict badge: PASS / NEEDS IMPROVEMENT / FAIL
  • Per-task token counts (prompt, completion, total)
  • Plan-level cost summary with grand total
  • Final response and generated files when the plan completes
  • Shareable URL per plan or per user session
Trust By Design

Built On Our AI Code of Ethics

The DAG Monitor isn't a cosmetic add-on — it's how we honor specific commitments from Notovision's AI Code of Ethics. Showing the work is how we earn confidence.

III

Communicate the plan, then keep users informed

“Communicate your plan clearly, then keep users informed as each step is executed to build confidence and trust.”

The monitor publishes the orchestrator's plan the moment it's created and streams every status change live. Users see the strategy before execution and watch each step happen.

I

Cite sources and explain methods

“Always cite your sources and explain your methods so users can verify what is true and trustworthy.”

Every node names the sub-agent that ran it, the model it used, the tools it called, and the cost it incurred — the full provenance of each piece of the answer is visible.

V

Never guess — show verified work

“Base every answer and action on verified information, rigorous reasoning, tested mathematics, and proven analytical methods.”

The evaluator's verdict (PASS / NEEDS IMPROVEMENT / FAIL) and numeric score appear next to every task. Users see the quality gate, not just the output.

IX

Acknowledge limits plainly

“When certainty is not possible, say so plainly and respectfully, and acknowledge the limits of your training or available evidence.”

Failed and skipped nodes stay on the graph, color-coded and labeled. Nothing is hidden when something doesn't work — the gaps in the answer are part of the answer.

II

Strong data stewardship

“Protect users through safe computing practices, strong data stewardship, and strict compliance with security regulations.”

Every plan, task, evaluator score, and cost record is persisted to PostgreSQL. The monitor is replaying a durable audit log, not an ephemeral feed.

VI

Transparent that this is an AI

“Be transparent at all times that you are an AI system, not a human being.”

The DAG visibly shows specialized AI sub-agents collaborating — data analysts, researchers, writers, evaluators. The mechanism is the message.

See the Work, Not Just the Answer
Live

The DAG Monitor turns sub-agent orchestration from a black box into a glass house. Every plan, every step, every score — visible the instant it happens.

Sub-Agent Orchestration → Our AI Code of Ethics

© 2026 NotoVision. All rights reserved. — NvAssistant Platform

error: Content is protected !!