1

main_step1.py

@@ -177,9 +177,9 @@ def step1(pid, experience=False, makeloop=True,task_distributed_id="",isNoColorT
     # TODO: 更新本地step1任务状态，加入step2任务队列
     if task_distributed_id == "":#不是分布式任务的时候就自动往下个步骤走，是分布式任务的时候就就执行当前任务
         if makeloop:
-            os.system(f'python main_step2.py {pid}')
+            os.system(f'python D://make2/main_step2.py {pid}')
         else:
-            os.system(f'python main_step2.py {pid}')
+            os.system(f'python D://make2/main_step2.py {pid}')
             # if os.path.exists(os.path.join(config.sharedir, pid)):
             #     shutil.rmtree(os.path.join(config.sharedir, pid), ignore_errors=True)
             # shutil.move(os.path.join(config.workdir, pid), config.sharedir)