feat: increase maximum concurrency for parallel agents to enhance performance
This commit is contained in:
@@ -320,9 +320,9 @@ pub fn run_workflow_tracked(
|
||||
}
|
||||
|
||||
let concurrency_cap = if script.options.max_concurrency > 0 {
|
||||
script.options.max_concurrency.min(8) // allow up to 8 parallel agents
|
||||
script.options.max_concurrency.min(10) // allow up to 10 parallel agents
|
||||
} else {
|
||||
4
|
||||
10
|
||||
};
|
||||
|
||||
let live_ref = live.as_ref();
|
||||
|
||||
+4
-4
@@ -43,8 +43,8 @@ impl Tool for SpawnAgents {
|
||||
},
|
||||
"max_concurrency": {
|
||||
"type": "integer",
|
||||
"description": "Maximum number of agents to run simultaneously (default: 4, max: 8).",
|
||||
"default": 4
|
||||
"description": "Maximum number of agents to run simultaneously (default: 10, max: 10).",
|
||||
"default": 10
|
||||
}
|
||||
},
|
||||
"required": ["agents"]
|
||||
@@ -68,8 +68,8 @@ impl Tool for SpawnAgents {
|
||||
|
||||
let max_concurrency = args.get("max_concurrency")
|
||||
.and_then(|v| v.as_u64())
|
||||
.map(|v| v.min(8) as usize)
|
||||
.unwrap_or(4);
|
||||
.map(|v| v.min(10) as usize)
|
||||
.unwrap_or(10);
|
||||
|
||||
let agent_count = agents.len();
|
||||
let primitives: Vec<ScriptPrimitive> = agents
|
||||
|
||||
Reference in New Issue
Block a user