我有一个工作流程。在
class WorkFlow1(Flow):
start = flow.StartFunction(function1) \
.Next(this.task2)
task2 = flow.StartFunction(function2) \
.Next(this.end)
end = flow.End()
@flow_start_func
def function1(activation, **kwargs):
print('Func1 Called.')
activation.prepare()
activation.done()
return activation
@flow_start_func
def function2(activation, **kwargs):
print('Func2 Called.')
activation.prepare()
activation.done()
return activation
我能够使用编程方式运行工作流
^{pr2}$它完美地启动了工作流,但是,并没有完成它。上面代码段的输出是
Func1 Called
完成工作流的Node1(start)后,不调用task2
。也就是说,只调用工作流的第一个任务,而不调用后续任务。为什么?如何执行完整的工作流程?在
StartFunction节点创建新的流实例。不能将一个启动功能连接到另一个启动功能。在
若要继续现有流,请使用
flow.Function
,如果需要从外部触发函数,则使用flow.Handler
立即继续。在相关问题 更多 >
编程相关推荐