From dffc47641ef1c2ed0adc9fc681bdada86c06a100 Mon Sep 17 00:00:00 2001
From: dongchangxi <458593490@qq.com>
Date: Fri, 27 Dec 2024 20:29:54 +0800
Subject: [PATCH] =?UTF-8?q?=E5=AE=9A=E6=97=B6=E8=AF=BB=E5=8F=96=E4=BB=BB?=
 =?UTF-8?q?=E5=8A=A1=E6=B2=A1=E6=9C=89=E5=88=86=E5=B8=83=E5=BC=8F=E7=9A=84?=
 =?UTF-8?q?=E6=A6=82=E5=BF=B5?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 timer/get_task_to_db.py | 22 +++++++++++-----------
 1 file changed, 11 insertions(+), 11 deletions(-)

diff --git a/timer/get_task_to_db.py b/timer/get_task_to_db.py
index 569fe4d..d797452 100644
--- a/timer/get_task_to_db.py
+++ b/timer/get_task_to_db.py
@@ -59,17 +59,17 @@ def readTask(key):
         print("走新的建模系统不是分布式插入-重建工单",key,pid,psid)
         libs_db.add_task(taskData)
     else:
-        intPid = int(psid)
-        if intPid == 29 or intPid == 94 or intPid == 51:
-            libs_db.add_task(taskData)
-        elif int(psid) <= 90 and int(psid) != 29 and int(psid) != 56 and int(psid) != 1:
-            print("走分布式建模",key,pid,psid)
-            if int(psid) == 41 or int(psid) == 85:
-                taskData["priority"] = 0
-            libs_db.add_task_distributed(taskData)
-        else:
-            print("非分布式建模",key,pid,psid)
-            libs_db.add_task(taskData)
+        # intPid = int(psid)
+        # if intPid == 29 or intPid == 94 or intPid == 51:
+        #     libs_db.add_task(taskData)
+        # elif int(psid) <= 90 and int(psid) != 29 and int(psid) != 56 and int(psid) != 1:
+        #     print("走分布式建模",key,pid,psid)
+        #     if int(psid) == 41 or int(psid) == 85:
+        #         taskData["priority"] = 0
+        #     libs_db.add_task_distributed(taskData)
+        # else:
+        print("非分布式建模",key,pid,psid)
+        libs_db.add_task(taskData)
 #程序主入口
 if __name__ == '__main__':
     atexit.register(common.notify,"定时读取建模任务已经停止")