mirror of
https://github.com/bytedance/deer-flow.git
synced 2026-09-11 06:28:58 +00:00
ff0a6768c2
* feat(subagents): add capacity controls and durable batches * fix(helm): sync subagent config schema version * fix(subagents): preserve batch history without worker * fix(subagents): support explicit factory runtimes * fix: address durable batch review findings
33 lines
990 B
Python
33 lines
990 B
Python
"""Startup-only process capacity for native subagent execution."""
|
|
|
|
from typing import Literal
|
|
|
|
from pydantic import BaseModel, Field
|
|
|
|
|
|
class SubagentRuntimeConfig(BaseModel):
|
|
"""Process-local admission and execution limits shared by all subagents."""
|
|
|
|
max_running: int = Field(
|
|
default=3,
|
|
ge=1,
|
|
le=64,
|
|
description="Maximum native subagents that may execute concurrently in one Gateway process.",
|
|
)
|
|
max_queued: int = Field(
|
|
default=64,
|
|
ge=0,
|
|
le=10_000,
|
|
description="Maximum native subagents waiting for a process execution slot.",
|
|
)
|
|
admission_policy: Literal["queue", "reject"] = Field(
|
|
default="queue",
|
|
description="Whether a full execution pool queues work or rejects it immediately.",
|
|
)
|
|
queue_timeout_seconds: int = Field(
|
|
default=300,
|
|
ge=1,
|
|
le=86_400,
|
|
description="Maximum wait for a queued native subagent before it fails admission.",
|
|
)
|