From 146fe6641f2ad2429c79b214a2e4a5ac524ccdb8 Mon Sep 17 00:00:00 2001
From: caoqianming <caoqianming@foxmail.com>
Date: Mon, 31 Mar 2025 15:11:43 +0800
Subject: [PATCH] =?UTF-8?q?feat:=20get=5Fbatch=5Fdag=E8=8A=82=E7=82=B9?=
 =?UTF-8?q?=E6=8E=92=E5=BA=8F=E6=94=B9=E5=8A=A8?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 apps/wpm/services.py | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/apps/wpm/services.py b/apps/wpm/services.py
index ff28613d..35678c0c 100644
--- a/apps/wpm/services.py
+++ b/apps/wpm/services.py
@@ -944,7 +944,7 @@ def get_batch_dag(batch_number: str):
             # 查询所有与当前批次相关的记录（作为source或target）
             logs = BatchLog.objects.filter(Q(source__id__in=nodes_set) | Q(target__id__in=nodes_set)).select_related(
                 "source", "target"
-            ).order_by("create_time")
+            ).order_by("update_time")
             # 处理每条记录，扩展节点和边
             for log in logs:
                 source = log.source.id
@@ -964,7 +964,7 @@ def get_batch_dag(batch_number: str):
         #         unique_edges[key] = edge
         
         # 将批次号排序
-        nodes_qs = BatchSt.objects.filter(id__in=nodes_set).order_by('id')
+        nodes_qs = BatchSt.objects.filter(id__in=nodes_set).order_by('update_time')
         
         # batch_to_id = {batch: idx for idx, batch in enumerate(nodes_list)}
         # 构建节点数据，默认使用'rect'形状