From 11d7e1a772ab9fa9ca39a29f3823f633e9f02de5 Mon Sep 17 00:00:00 2001
From: caoqianming <caoqianming@foxmail.com>
Date: Tue, 25 Mar 2025 09:51:25 +0800
Subject: [PATCH] feat: get_batch_dag bug

---
 apps/wpm/services.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/apps/wpm/services.py b/apps/wpm/services.py
index bc3877df..61609fb3 100644
--- a/apps/wpm/services.py
+++ b/apps/wpm/services.py
@@ -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