dolphinscheduler 使用python组件写一段循环调用SUB_PROCESS组件的代码
时间: 2023-04-11 15:02:03 浏览: 201
大数据精通组件——DolphinScheduler⼯作流调度引擎
可以使用以下代码实现:
```python
from dolphin.scheduler.api import process_definition
from dolphin.scheduler.api import process_instance
# 获取 SUB_PROCESS 组件的定义
sub_process_def = process_definition.get_process_definition_by_name("SUB_PROCESS")
# 循环调用 SUB_PROCESS 组件
for i in range(10):
sub_process_instance = process_instance.create_process_instance(sub_process_def["id"])
process_instance.start_process_instance(sub_process_instance["id"])
```
注意:以上代码仅供参考,具体实现可能需要根据实际情况进行调整。
阅读全文