47 lines
1.0 KiB
Python
47 lines
1.0 KiB
Python
import asyncio
|
|
import sys
|
|
import os
|
|
|
|
sys.path.insert(0, os.path.dirname(__file__))
|
|
|
|
from src.agent.graph.pipeline import pipeline
|
|
|
|
|
|
async def main():
|
|
print("=" * 60)
|
|
print("Запуск pipeline оркестратора")
|
|
print("=" * 60)
|
|
|
|
result = await pipeline.ainvoke({
|
|
"tasks": [],
|
|
"current_index": 0,
|
|
"results": [],
|
|
"errors": [],
|
|
})
|
|
|
|
print("\n" + "=" * 60)
|
|
print("ИТОГ")
|
|
print("=" * 60)
|
|
|
|
results = result.get("results", [])
|
|
errors = result.get("errors", [])
|
|
|
|
print(f"Выполнено заданий: {len(results)}")
|
|
for r in results:
|
|
tid = r.get("task_id", "")[:8]
|
|
status = r.get("status", "?")
|
|
mode = r.get("mode", "?")
|
|
retries = r.get("retries", 0)
|
|
print(f" {tid}... [{status}] mode={mode} retries={retries}")
|
|
|
|
if errors:
|
|
print(f"\nОшибки ({len(errors)}):")
|
|
for e in errors:
|
|
print(f" - {e}")
|
|
else:
|
|
print("\nОшибок нет.")
|
|
|
|
|
|
if __name__ == "__main__":
|
|
asyncio.run(main())
|