Adolfo Delorenzo
8257c554d7
- Create orchestrator/main.py: Celery app with Redis broker/backend, task_acks_late=True, 10-min timeout - Create orchestrator/tasks.py: SYNC def handle_message (critical pattern: asyncio.run for async work) - Deserializes KonstructMessage, sets RLS context, loads agent from DB, calls run_agent - Retries up to 3x on deserialization failure - Create orchestrator/agents/builder.py: build_system_prompt assembles system_prompt + identity + persona + AI transparency clause - Create orchestrator/agents/runner.py: run_agent posts to llm-pool /complete via httpx, returns polite fallback on error - Add Celery[redis] dependency to orchestrator pyproject.toml - Create tests/integration/test_llm_fallback.py: 7 tests for fallback routing and 503 on total failure (LLM-01) - Create tests/integration/test_llm_providers.py: 12 tests verifying all three providers configured correctly (LLM-02) - All 19 integration tests pass
22 lines
497 B
TOML
22 lines
497 B
TOML
[build-system]
|
|
requires = ["hatchling"]
|
|
build-backend = "hatchling.build"
|
|
|
|
[project]
|
|
name = "konstruct-orchestrator"
|
|
version = "0.1.0"
|
|
description = "Agent Orchestrator — agent selection, tool dispatch, memory, handoffs"
|
|
requires-python = ">=3.12"
|
|
dependencies = [
|
|
"konstruct-shared",
|
|
"fastapi[standard]>=0.115.0",
|
|
"celery[redis]>=5.4.0",
|
|
"httpx>=0.28.0",
|
|
]
|
|
|
|
[tool.uv.sources]
|
|
konstruct-shared = { workspace = true }
|
|
|
|
[tool.hatch.build.targets.wheel]
|
|
packages = ["orchestrator"]
|