From 8367ac187a5b3d439bc386822f23fdc5eb236748 Mon Sep 17 00:00:00 2001 From: Hamed Gorjiara Date: Tue, 15 Oct 2019 12:00:24 -0700 Subject: [PATCH] storing results in /rscratch instead of home dir --- src/Scripts/remotelearning.py | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) diff --git a/src/Scripts/remotelearning.py b/src/Scripts/remotelearning.py index dccee9c..1f2967d 100644 --- a/src/Scripts/remotelearning.py +++ b/src/Scripts/remotelearning.py @@ -67,7 +67,7 @@ def startLearningProcess(benchmark, server, learningSet): LOGFILE= benchmark + "-" + str(learningSet) + ".log" print("Running benchmark " + benchmark + "(Set="+ str(learningSet)+") on server") COMMAND=("cd "+SRCDIR+"; ./Scripts/learnresultgen.sh " + - benchmark + " " + str(learningSet) + " " + ALGORITHM + " &> " + LOGFILE + "; mv *.csv ~/; echo 'SUCCESS'") + benchmark + " " + str(learningSet) + " " + ALGORITHM + " &> " + LOGFILE + "; mv *.csv /rscratch/hamed/; echo 'SUCCESS'") print("Calling the following command:\n" + COMMAND) ssh = subprocess.Popen(["ssh", "%s" % HOST, COMMAND], shell=False, @@ -88,11 +88,12 @@ def moveCSVFiles(): def main(): benchmark = ArgParser().getBenchmarkName() -# print("Deploying on all the servers ...") -# deploy() + #print("Deploying on all the servers ...") + #deploy() serverNumber = getServerNeeded(benchmark) print("Learning on " + benchmark + " needs " + str(serverNumber) + " servers.") - availableServers = getAvailableServerList(serverNumber) + #availableServers = getAvailableServerList(serverNumber) + availableServers = [4, 5, 6, 7] print ("Available Server:" + str(availableServers)) if serverNumber > len(availableServers): print("Servers are busy. We don't have enough server available for learning ...") -- 2.34.1