# deploy/dynamo/sdk/src/dynamo/sdk/cli/serve.py

@click.command()
@click.argument("bento", type=click.STRING, default=".")
@click.option(
    "-f", "--file",
    type=click.Path(exists=True),
    help="配置文件路径"
)
@click.option(
    "--port",
    type=int,
    default=3000,
    help="HTTP 服务端口"
)
@click.option(
    "--host",
    type=str,
    default="0.0.0.0",
    help="HTTP 服务地址"
)
@click.option(
    "--development",
    is_flag=True,
    help="开发模式（热重载）"
)
@click.option(
    "--dry-run",
    is_flag=True,
    help="仅验证配置，不启动服务"
)
def serve(
    ctx,
    bento: str,
    file: str | None,
    port: int,
    host: str,
    development: bool,
    dry_run: bool,
):
    """
    启动 Dynamo 服务

    BENTO: 服务图模块路径，格式为 module:attribute
    """
    ...

# graphs/agg.py

from ..components.worker import VllmWorker
from ..components.processor import Processor
from ..components.frontend import Frontend

# 定义服务图入口
# 依赖关系：Frontend -> Processor -> VllmWorker
Frontend = Frontend

# configs/agg.yaml

# 服务名: 配置
VllmWorker:
  # 类属性（直接映射）
  model_path: /models/llama-7b
  tensor_parallel_size: 1
  max_model_len: 16384

  # 服务参数
  ServiceArgs:
    workers: 2
    resources:
      gpu: 1
      cpu: "10"
      memory: "64Gi"

Processor:
  batch_size: 32

  ServiceArgs:
    workers: 4
    resources:
      cpu: "4"

Frontend:
  port: 8080

  ServiceArgs:
    workers: 1

def _parse_service_graph(graph):
    """
    解析服务依赖图，返回拓扑排序

    Returns:
        按依赖顺序排列的服务列表
    """
    services = []
    visited = set()

    def visit(svc):
        if svc.name in visited:
            return
        visited.add(svc.name)

        # 先访问依赖（深度优先）
        for dep in svc._dependencies:
            if hasattr(dep, 'on') and dep.on:
                visit(dep.on)

        services.append(svc)

    visit(graph)
    return services

def _apply_config(service, config: dict) -> None:
    """应用配置到服务"""

    # 1. 类属性
    for key, value in config.items():
        if key not in ("ServiceArgs", "dynamo"):
            if hasattr(service.inner, key):
                setattr(service.inner, key, value)

    # 2. Dynamo 配置
    if "dynamo" in config:
        _apply_dynamo_config(service, config["dynamo"])

    # 3. 服务参数
    if "ServiceArgs" in config:
        _apply_service_args(service, config["ServiceArgs"])

# configs/dev.yaml
VllmWorker:
  model_path: /models/llama-7b
  ServiceArgs:
    workers: 1
    resources:
      gpu: 1

Processor:
  ServiceArgs:
    workers: 2

Frontend:
  ServiceArgs:
    workers: 1