线下设计开发任务流


本章节介绍如何在任务流设计页面的编辑画布中,设计开发任务流。

浏览线下设计页面

点击实验列表中目标实验的 线下设计,可进入到线下设计编辑画布,开始任务流设计和开发。线下设计页面由以下部分组成:


算子列表

线下设计页面左侧为各类算子列表,提供逻辑算子、模型算子、SQL算子、文件算子、处理算子、自定义算子等,并可在页面顶端的搜索框中搜索算子。


编辑画布

线下设计页面中部为任务流编辑画布,可将需要使用的算子拖拽到编辑画布中,编排任务流。


参数配置

线下设计页面右侧为参数配置区,可对任务流或算子进行基础信息配置和参数配置。


功能操作

线下设计页面顶部为功能操作区,可对任务流进行以下操作:

  • 自动保存:开启或关闭自动保存编辑中的任务流信息。

  • 保存:保存当前画布中的任务流信息。

  • 撤销/重做:回退或重做画布中的任务流信息。

  • 运行:测试运行当前任务流。

  • 导出:导出并保存当前任务流配置信息。

  • 导入:导入外部保存的任务流配置文件,在编辑画布上编辑。

  • 查看运行实例:可查看线上运行中的任务流实例列表。

  • 发布生产:将当前任务流发布至生产环境。首次发布任务流时需要设置生产环境调度,任务流发布至生产环境后,其状态由编辑态变为生产中状态。如果生产环境已有运行中的实例,新发布的任务流将覆盖生产环境中的任务流。


../_images/workflow_desgin_page.png

编排任务流

通过拖拽算子至任务流编辑画布、设置每个算子的配置信息、使用箭头将算子连接起来表示算子间的逻辑依赖关系,编排为任务流。最后通过配置整个任务流的调度周期,实现任务流自动运行。


本章节以 “抛硬币” 场景为例,使用 Condition 算子和自定义的 flip-coin-op 和 print-op 算子,编排任务流,输出结果为硬币的正面。


通过以下步骤,完成任务流和算子的参数配置,并将算子编排为任务流。

  1. 将需要使用的算子(1个 flip-coin-op 算子和2个 Condition 算子)拖拽到编辑画布中。

  2. 选中 Condition 算子,在其参数配置中,引用 flip-coin-op 算子的 output 值作为 Condition 算子的表达式:flip-coin-op.output == heads

    ../_images/workflow_config_1.png
  3. 选中 Condition(1) 算子,在其参数配置中,引用 flip-coin-op 算子的 output 值作为 Condition(1) 算子的表达式:flip-coin-op.output == tails

    ../_images/workflow_config_2.png
  4. 双击 Condition 算子,打开其子画布,将 print-op 算子拖拽到编辑画布中,引用 flip-coin-op 算子的 output 值,用于打印 flip-coin-op.output 的值。

    ../_images/workflow_config_3.png
  5. 参照步骤4,双击 Condition(1) 算子,在其子画布中配置 print-op 算子。

  6. 在主画布中,拖拽 flip-coin-op 算子的输出点,用箭头将其连接到2个 Condition 算子的输入点,表示算子之间的逻辑依赖关系,完成任务流的编排。

    ../_images/workflow_config_4.png

运行任务流

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

    ../_images/workflow_config_5.png
  2. 任务流开始运行后,点击功能操作区中的 查看运行实例 图标,在 运行实例列表 中,查看已运行的任务流实例。

    ../_images/workflow_list.png
  3. 点击运行名称,查看任务流实例的运行结果。

    ../_images/workflow_running_results.png