python from taskflow import task, flow, engine class PrintTask(task.Task): def execute(self, message): print(message) class AddTask(task.Task): def execute(self, a, b): return a + b print_task = PrintTask() add_task = AddTask() flow_engine = engine.Engine() print_task.message = "Hello, TaskFlow!" add_task.a = 2 add_task.b = 3 flow_instance = flow.Flow("my_flow").add(print_task, add_task) flow_engine.compile(flow_instance) flow_engine.run()


上一篇:
下一篇:
切换中文