Skip to content

Phase 3:调度集成 job-rpc(DolphinScheduler 管控面) #21

Open

Description

@jackluo2012

Part of #13

范围

  • 目录:job/rpc(:8092),表 dc_sync_task
  • 接口契约:job/rpc/job.proto(CreateSyncTask/ListSyncTasks/DeleteSyncTask/DeployToScheduler/TriggerTask/GetTaskStatus/GetSchedulerInfo)
  • 不自研调度:本服务只做管控面(任务定义/部署/触发/状态聚合),执行面推 DolphinScheduler OpenAPI(DS_BASE_URL/DS_TOKEN 环境变量配置)
  • DS 未配置/不可达时 Deploy/Trigger 返回 ok=false + 原因(业务结果,非 error)

状态

  • proto 契约 + 骨架
  • 实现(进行中,DS client 以 httptest 单测锁定请求/解析协议)
  • 真实 DolphinScheduler 3.x 联调(需实例)

验收

创建同步任务 → 部署(无 DS 时返回明确原因)→ 配置真实 DS 后部署回填 workflow_code → 触发 → 状态聚合。

Activity

  1. jackluo2012 commented on Oct 10, 2026

    @jackluo2012
    OwnerAuthor

    job-rpc 已实现并入 PR #20:DS OpenAPI 客户端(httptest 22 用例锁定协议)、任务管控/部署/触发/状态聚合、调度器运维视图。部署链路实测:未配置 DS 时返回明确配置指引。剩余:真实 DolphinScheduler 3.x 实例联调(TODO 已标注在 dsclient.go)。

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Metadata

Metadata

Assignees

No one assigned

    Labels

    No labels
    No labels

    Projects

    No projects

      Milestone

      No milestone

      Relationships

      None yet

      Development

      No branches or pull requests

      Issue actions