/
ncit
/
multiagentsystem
Обзор
Документация
Войти
/
ncit
/
multiagentsystem
Код
Запросы
0
Задачи
Вики
Пакеты
0
Релизы
0
CI/CD
Аналитика
Безопасность
master
api/src/workflows/registry.py
46 строк
2 KB
Nikita
feat: initial multi-agent platform scaffold
09 июн 2026, 00:48
09 июн 2026, 00:48
19cef10
Код
Авторство
О чём код?
"""Built-in workflow templates — pre-made DAG pipelines users can fork.""" from __future__ import annotations from src.workflows.engine import DAGEdge, DAGNode, NodeType, WorkflowDAG WORKFLOW_TEMPLATES: dict[str, WorkflowDAG] = { "blog-pipeline": WorkflowDAG( nodes=[ DAGNode(id="research", type=NodeType.AGENT, agent_type="researcher"), DAGNode(id="draft", type=NodeType.AGENT, agent_type="marketing-copywriter"), DAGNode(id="seo", type=NodeType.AGENT, agent_type="seo-analyst"), DAGNode(id="merge", type=NodeType.MERGE), ], edges=[ DAGEdge(from_node="research", to_node="draft"), DAGEdge(from_node="draft", to_node="seo"), DAGEdge(from_node="draft", to_node="merge"), DAGEdge(from_node="seo", to_node="merge"), ], ), "code-review-pipeline": WorkflowDAG( nodes=[ DAGNode(id="review", type=NodeType.AGENT, agent_type="code-reviewer"), DAGNode(id="fix", type=NodeType.AGENT, agent_type="coder"), ], edges=[ DAGEdge(from_node="review", to_node="fix"), ], ), "image-content-pipeline": WorkflowDAG( nodes=[ DAGNode(id="copywriter", type=NodeType.AGENT, agent_type="marketing-copywriter"), DAGNode(id="image-gen", type=NodeType.AGENT, agent_type="image-gen"), ], edges=[], # parallel — both run from root input ), } def list_workflow_templates() -> list[dict]: return [ {"id": wid, "node_count": len(w.nodes), "edge_count": len(w.edges)} for wid, w in WORKFLOW_TEMPLATES.items() ]