我有一个 API 端点,/api/create/
. 这会根据从客户端接收到的有效负载在数据库中创建一个新条目。
Payload - {
'field1': 'value1`,
'field2': 'value2`,
'field3': 'value3`,
'field4': 'value4`,
'type': 'A'
}
现在取决于type
,我有一个特定的工作流程。例如:-Type A
需要在保存数据之前执行某些任务,Type B
有自己的一组操作。
我没有任何 UI,只有来自 POST 请求的请求。我如何将django-viewflows用于这样的用例?
更新
我能够使用WorkFlowClass.start.run()
. 它完美地启动了工作流程。但是,不是完整的工作流程。完成工作流的 Node1(开始)后,它不会转到 Node2。意思是,只调用工作流的第一个任务,而不是后续任务。
这是我的工作流程。
class FunctionFlow1(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 function1(activation, **kwargs):
print('Func2 Called.')
activation.prepare()
activation.done()
return activation
task2
不叫。为什么?