Fine-tuning/backend/app/services/training_service.py

from typing import Any

from app.config import get_settings
from app.core.logging import logger

settings = get_settings()


async def create_training_job(config: dict[str, Any]) -> dict[str, Any]:
    """校验配置、创建任务记录、加入队列。"""
    logger.info(f"Creating training job: model={config.get('model_id')}")
    return {"job_id": "placeholder", "status": "queued"}


async def cancel_training_job(job_id: str) -> dict[str, Any]:
    """向运行中的任务发送取消信号。"""
    logger.info(f"Cancelling job {job_id}")
    return {"status": "cancelled"}