单元 5. 运行和发布任务流


完成任务流编排和配置后，可运行任务流，查看运行结果。任务流运行成功后，可将任务流发布上线生产。

运行任务流

  1. 保存任务流后，点击功能操作区中的 运行 图标。在弹窗中，完成运行任务流的资源配置后，点击 确认。

    ../_images/running_pipeline.png

  2. 任务流运行成功后，点击页面右上角的 查看运行实例 图标，在 运行实例列表 中，查看成功运行的任务流实例。

    ../_images/pipeline_instance_list.png

  3. 点击运行名称，查看任务流实例的运行结果。在 DAG图 标签下，选中任一算子，在右侧弹窗中查看任务流中每个算子的运行结果，包括算子的输入输出参数、运行日志、和Pod信息。

    ../_images/pipeline_operator_results.png

将任务流发布生产

任务流运行成功后，可将任务流发布生产并调度，实现任务流自动运行。

  1. 在实验列表中，从实验名称卡片右上角的 … 菜单中选择 发布生产。或在线下设计页面中，点击页面右上角的 发布 按钮。

  2. 在 发布生产 弹窗中，完成基础配置后，点击 下一步。

    ../_images/publishing_pipeline_1.png

  3. 完成生产调度配置：

    • 触发类型：选择按固定频率周期调度任务流或按指定时间（通过Cron表达式配置）调度任务流

    • 设定调度任务流的开始时间和结束时间

    • 若按固定频率周期调度任务流，设定运行时间间隔

    • 若按指定时间调度任务流，输入Cron表达式

    ../_images/publishing_pipeline_2.png

  4. 完成任务流调度配置后，点击 确认，将任务流发布上线生产，实验的状态将变为 已调度。

  5. 从实验名称卡片右上角的 … 菜单中选择 查看调度，即可查看调度的详细信息。