假设我有一个 Process 有两个可选的 View 任务完成:
--> Split --> optional_view_1 ---> Join ----> finish
| ^
| |
-----> optional_view_2 -------
假设两个任务都已分配,但有人登录并完成了 optional_view_1。Join 本身和 End 节点都以 DONE 状态结束。但是,由于 optional_view_2,进程会卡住并且不会干净地退出。
问题是:
- 如何干净地完成这个过程(即不取消它)并且没有比赛
- 从哪里(例如,在每个视图之后从 Join 或 Handler 内部取消另一个?)
我最初将此作为问题发布,以及可能的编码解决方案。总结一下代码:
- 覆盖与加入关联的激活“完成”
- 覆盖检查 Join 是否具有 wait_all=False
- 如果是这样,尝试查找 Join 正在等待的任何其他任务
- 并取消它们
第 3 步的代码是我最担心的一点。它是处理 wait_all=True 情况的 Viewflow 代码的修改版本,总结如下:
previous = self.task.previous.exclude(status=STATUS.CANCELED).all()
join_prefixes = set(prev.token.get_common_split_prefix(self.task.token, prev.pk)
for prev in previous)
#
# Don't forget to exclude the previous tasks.
#
join_token_prefix = next(iter(join_prefixes))
active = self.flow_class.task_class._default_manager \
.filter(process=self.process, token__startswith=join_token_prefix) \
.exclude(status__in=[STATUS.DONE, STATUS.CANCELED], pk__in=[prev.pk for prev in previous])
for task in active:
cancel_task(task)
欢迎就这是否是正确的方法发表评论。