I forgot about show the graphic for what we define in Python API. When we 
declare `pd.run()`,
all model will post to Apache DolphinScheduler server, it would create a dag 
graphic as below

                           --> task_child_one
                         /                               \
task_parent -->                                  -->  task_union
                         \                               /
                           --> task_child_two

You could also find this graphic in tutorial.py[1] too

[1]: 
https://github.com/apache/dolphinscheduler/pull/6269/files#diff-5561fec6b57cc611bee2b0d8f030965d76bdd202801d9f8a1e2e74c21769bc41


Best Wish
— Jiajie


> ```python
> from pydolphinscheduler.core.process_definition import ProcessDefinition
> from pydolphinscheduler.tasks.shell import Shell
> 
> with ProcessDefinition(name="tutorial") as pd:
>     task_parent = Shell(name="task_parent", command="echo hello 
> pydolphinscheduler")
>     task_child_one = Shell(name="task_child_one", command="echo 'child one'")
>     task_child_two = Shell(name="task_child_two", command="echo 'child two'")
>     task_union = Shell(name="task_union", command="echo union")
> 
>     task_group = [task_child_one, task_child_two]
>     task_parent.set_downstream(task_group)
> 
>     task_union << task_group
> 
>     pd.run()
> ```

Reply via email to