我有一个工作流程。
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我可以使用以下命令以编程方式运行工作流
`WorkFlowClass.start.run()`. 它完美地启动了工作流程,但并没有完成它。上述代码片段的输出为
Func1 Called工作流启动(Node1)完成后,不会调用task2。这意味着,只调用工作流的第一个任务,而不调用后续任务。为什么?我如何执行完整的工作流程?
发布于 2018-03-06 13:58:28
StartFunction节点创建新的流程实例。您不能将一个启动函数连接到另一个启动函数。
若要继续现有流程,请使用flow.Function (如果函数需要从外部触发),或使用flow.Handler立即继续。
https://stackoverflow.com/questions/49026356
复制相似问题