clan: restore zhos_mvp profile in crewai-service and re-enable clan zhos routing
This commit is contained in:
@@ -15,6 +15,7 @@ CREWAI_URL = os.getenv("CREWAI_URL", "http://dagi-staging-crewai-service:9010")
|
||||
CREWAI_ENABLED = os.getenv("CREWAI_ENABLED", "true").lower() == "true"
|
||||
CREWAI_ORCHESTRATORS_ALWAYS = os.getenv("CREWAI_ORCHESTRATORS_ALWAYS", "true").lower() == "true"
|
||||
HELION_CREWAI_TEAM_LIMIT = int(os.getenv("HELION_CREWAI_TEAM_LIMIT", "3"))
|
||||
CLAN_CREWAI_PROFILE = os.getenv("CLAN_CREWAI_PROFILE", "zhos_mvp")
|
||||
|
||||
CREWAI_AGENTS_PATH = os.getenv("CREWAI_AGENTS_PATH", "/config/crewai_agents.json")
|
||||
FALLBACK_CREWAI_PATH = "/app/config/crewai_agents.json"
|
||||
@@ -133,6 +134,8 @@ async def call_crewai(agent_id, task, context=None, team=None, profile=None):
|
||||
|
||||
async with httpx.AsyncClient(timeout=600.0) as client:
|
||||
effective_profile = profile or (effective_context.get("metadata", {}) or {}).get("crewai_profile")
|
||||
if not effective_profile and agent_id == "clan" and CLAN_CREWAI_PROFILE:
|
||||
effective_profile = CLAN_CREWAI_PROFILE
|
||||
|
||||
payload = {
|
||||
"task": task,
|
||||
|
||||
Reference in New Issue
Block a user