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