2. 任务调度平台核心模型：实体关系与状态机

任务调度平台的核心在于对 Task（任务）、Job（作业）、Workflow（工作流）、Trigger（触发器） 和 Executor（执行器） 这五大实体的抽象与编排。理解它们之间的实体关系以及各自的状态机，是设计 OpenAPI 和事件驱动架构的基础。

2.1 五大核心实体定义

2.2 实体关系模型

五大实体通过以下关键关系构成调度平台的骨架：

• Job 与 Task：一对多关系。一个 Job 包含一个或多个 Task，Task 在 Job 的上下文中按顺序或并行执行。
• Workflow 与 Job：一对多关系。一个 Workflow 由多个 Job 组成，通过 DAG 边定义依赖（如 Job B 必须在 Job A 完成后启动）。
• Trigger 与 Job/Workflow：多对多关系。一个 Trigger 可以绑定多个 Job 或 Workflow；一个 Job 也可以被多个 Trigger 触发。
• Executor 与 Task：一对多关系。一个 Executor 在同一时刻可运行多个 Task，但每个 Task 只能分配给一个 Executor。

2.3 核心状态机

每个实体都拥有独立的状态机，状态转换是事件驱动的核心。下面以 Task 和 Job 为例说明。

2.3.1 Task 状态机

2.3.2 Job 状态机

2.4 实体关系在 OpenAPI 中的体现

在 OpenAPI 规范中，实体关系通过资源嵌套和引用表达：

# 示例：Job 资源定义（OpenAPI 3.0 片段）
components:
  schemas:
    Job:
      type: object
      properties:
        id:
          type: string
          format: uuid
        name:
          type: string
        tasks:
          type: array
          items:
            $ref: '#/components/schemas/TaskRef'  # 引用 Task
        trigger_id:
          type: string
          description: "绑定的 Trigger ID"
        executor_group:
          type: string
          description: "执行器标签，用于调度匹配"
        state:
          $ref: '#/components/schemas/JobState'
    TaskRef:
      type: object
      properties:
        task_id:
          type: string
        order:
          type: integer
          description: "执行顺序"

2.5 状态机与事件驱动的映射

每个状态转换对应一个 Kafka 事件主题（Topic），事件结构遵循统一格式：