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,"定时读取建模任务已经停止")