|
|
@@ -26,13 +26,13 @@ def launch(node, manifest, config, cmd, log_folder, epoch_time, num_epochs, num_
|
|
|
cmdline = manifestdata['launchprefix'] + ' '
|
|
|
cmdline += TEEMS + " -k %s -n %s" % (manifestdata['sprvfile'], node)
|
|
|
|
|
|
- if(epoch_time):
|
|
|
+ if epoch_time:
|
|
|
cmdline+= ' -d ' + str(epoch_time)
|
|
|
|
|
|
- if(num_epochs):
|
|
|
+ if num_epochs:
|
|
|
cmdline+= ' -e ' + str(num_epochs)
|
|
|
|
|
|
- if(num_WN):
|
|
|
+ if num_WN:
|
|
|
cmdline+= ' -w ' + str(num_WN)
|
|
|
|
|
|
if 'args' in manifestdata:
|
|
|
@@ -40,7 +40,7 @@ def launch(node, manifest, config, cmd, log_folder, epoch_time, num_epochs, num_
|
|
|
|
|
|
log_name = None
|
|
|
stdout_file = subprocess.PIPE
|
|
|
- if(log_folder):
|
|
|
+ if log_folder:
|
|
|
log_name = log_folder + node + ".log"
|
|
|
stdout_file = open(log_name, "a+")
|
|
|
|
|
|
@@ -50,7 +50,7 @@ def launch(node, manifest, config, cmd, log_folder, epoch_time, num_epochs, num_
|
|
|
stderr=subprocess.STDOUT, bufsize=0)
|
|
|
proc.stdin.write(config.encode('utf-8'))
|
|
|
|
|
|
- if(log_folder == None):
|
|
|
+ if log_folder is None:
|
|
|
while True:
|
|
|
line = proc.stdout.readline()
|
|
|
if not line:
|
|
|
@@ -83,7 +83,7 @@ if __name__ == "__main__":
|
|
|
aparse.add_argument('-l', default=None,
|
|
|
help='log folder to store logs of each server in an experiment')
|
|
|
aparse.add_argument('-d', default=None,
|
|
|
- help='Set epoch interval time in seconds')
|
|
|
+ help='Set epoch wait time in seconds')
|
|
|
aparse.add_argument('-e', default=None,
|
|
|
help='Set number of epochs')
|
|
|
aparse.add_argument('-w', default=None,
|
