Use /var/tmp/jasminegraph/logs as log path

miyurud · Jan 27, 2024 · 7c20963 · 7c20963
1 parent 05d31b5
commit 7c20963
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 7 deletions.
diff --git a/src/server/JasmineGraphInstanceService.cpp b/src/server/JasmineGraphInstanceService.cpp
@@ -952,9 +952,8 @@ void JasmineGraphInstanceService::trainPartition(string trainData) {
     std::transform(trainargs.begin(), trainargs.end(), std::back_inserter(vc), converter);
 
     std::string path = "cd " + Utils::getJasmineGraphProperty("org.jasminegraph.graphsage") + " && ";
-    std::string command =
-        path + "python3 -m unsupervised_train >  /home/ubuntu/software/jasminegraph/logs/unsupervised_train" +
-        partitionID + "-" + Utils::getCurrentTimestamp() + ".txt";
+    std::string command = path + "python3 -m unsupervised_train >  /var/tmp/jasminegraph/logs/unsupervised_train" +
+                          partitionID + "-" + Utils::getCurrentTimestamp() + ".txt";
 
     int argc = trainargs.size();
     for (int i = 0; i < argc - 2; ++i) {
@@ -1946,7 +1945,7 @@ void JasmineGraphInstanceService::initOrgServer(string trainData) {
     std::string command = path + "python3 org_server.py " + graphID + " " +
                           Utils::getJasmineGraphProperty("org.jasminegraph.fl_clients") + " " +
                           Utils::getJasmineGraphProperty("org.jasminegraph.fl.epochs") +
-                          " localhost 5050 > /home/ubuntu/software/jasminegraph/logs/org_server_logs-" +
+                          " localhost 5050 > /var/tmp/jasminegraph/logs/org_server_logs-" +
                           Utils::getCurrentTimestamp() + ".txt";
     instance_logger.info("Executing : " + command);
     int exit_status = system(command.c_str());
@@ -1976,7 +1975,7 @@ void JasmineGraphInstanceService::initAgg(string trainData) {
                           Utils::getJasmineGraphProperty("org.jasminegraph.fl.dataDir") + " " + "4" + " 0 " +
                           Utils::getJasmineGraphProperty("org.jasminegraph.fl.num.orgs") + " " +
                           Utils::getJasmineGraphProperty("org.jasminegraph.fl.epochs") + " localhost 5000 > " +
-                          "/home/ubuntu/software/jasminegraph/logs/agg_logs-" + Utils::getCurrentTimestamp() + ".txt";
+                          "/var/tmp/jasminegraph/logs/agg_logs-" + Utils::getCurrentTimestamp() + ".txt";
     instance_logger.info("Executing : " + command);
     int exit_status = system(command.c_str());
     if (exit_status == -1) {

diff --git a/src/server/JasmineGraphServer.cpp b/src/server/JasmineGraphServer.cpp
@@ -427,7 +427,7 @@ void JasmineGraphServer::startRemoteWorkers(std::vector<int> workerPortsVector,
                         "docker run -v " + instanceDataFolder + ":" + instanceDataFolder + " -v " +
                         aggregateDataFolder + ":" + aggregateDataFolder + " -v " + nmonFileLocation + ":" +
                         nmonFileLocation + " -v " + instanceDataFolder + "/" + to_string(i) + "/logs" + ":" +
-                        "/home/ubuntu/software/jasminegraph/logs" + " -p " + std::to_string(workerPortsVector.at(i)) +
+                        "/var/tmp/jasminegraph/logs" + " -p " + std::to_string(workerPortsVector.at(i)) +
                         ":" + std::to_string(workerPortsVector.at(i)) + " -p " +
                         std::to_string(workerDataPortsVector.at(i)) + ":" +
                         std::to_string(workerDataPortsVector.at(i)) + " -e WORKER_ID=" + to_string(i) +
@@ -450,7 +450,7 @@ void JasmineGraphServer::startRemoteWorkers(std::vector<int> workerPortsVector,
                         "docker -H ssh://" + host + " run -v " + instanceDataFolder + ":" + instanceDataFolder +
                         " -v " + aggregateDataFolder + ":" + aggregateDataFolder + " -v " + nmonFileLocation + ":" +
                         nmonFileLocation + " -v " + instanceDataFolder + "/" + to_string(i) + "/logs" + ":" +
-                        "/home/ubuntu/software/jasminegraph/logs" + " -p " + std::to_string(workerPortsVector.at(i)) +
+                        "/var/tmp/jasminegraph/logs" + " -p " + std::to_string(workerPortsVector.at(i)) +
                         ":" + std::to_string(workerPortsVector.at(i)) + " -p " +
                         std::to_string(workerDataPortsVector.at(i)) + ":" +
                         std::to_string(workerDataPortsVector.at(i)) + " -e WORKER_ID=" + to_string(i) +