zcdsj
/
factory
5
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

feat: get_batch_dag bug

This commit is contained in:
caoqianming 2025-03-25 09:51:25 +08:00
parent 52b96dc740
commit 11d7e1a772
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
apps/wpm/services.py
View File

@ -915,7 +915,7 @@ def get_batch_dag(batch_number: str):
while len(nodes_set) > prev_size:
prev_size = len(nodes_set)
# 查询所有与当前批次相关的记录（作为source或target）
logs = BatchLog.objects.filter(Q(source_b__in=nodes_set) | Q(target_b__in=nodes_set)).order_by("create_time")
logs = BatchLog.objects.filter(Q(source__id__in=nodes_set) | Q(target__ide__in=nodes_set)).order_by("create_time")
# 处理每条记录，扩展节点和边
for log in logs:
source = log.source.id