Fix k8s cluster job rerunable

8 years ago · 9059eea4f4
parent 1f7134c626
commit 9059eea4f4
1 changed files with 2 additions and 1 deletions
--- a/doc/howto/usage/k8s/src/k8s_train/start_paddle.py
+++ b/doc/howto/usage/k8s/src/k8s_train/start_paddle.py
@ -132,7 +132,8 @@ def startPaddle(idMap={}, train_args_dict=None):
    logDir = JOB_PATH_OUTPUT + "/node_" + str(trainerId)
    if not os.path.exists(JOB_PATH_OUTPUT):
        os.makedirs(JOB_PATH_OUTPUT)
-    os.mkdir(logDir)
+    if not os.path.exists(logDir):
+        os.mkdir(logDir)
    copyCommand = 'cp -rf ' + JOB_PATH + \
        "/" + str(trainerId) + "/data/*" + " ./data/"
    os.system(copyCommand)