Commit 7861e5d2 authored by faquin's avatar faquin
Browse files

Add possibility to have full size parameter name

Some environnement like Spark do not send the argument with only one
dash. Allow the MPI_EXECUTOR to send arguments with the full name.
parent 12c21166
...@@ -6,10 +6,16 @@ from .mpi_jail import MPIJail ...@@ -6,10 +6,16 @@ from .mpi_jail import MPIJail
class MPIExecutor(Executor): class MPIExecutor(Executor):
def __init__(self, name, command, jail, end=False, timeout=-1, def __init__(self, name, command, jail, end=False, timeout=-1,
encoding=consts.encoding) : encoding=consts.encoding,
long_opt=False) :
Executor.__init__(self, jail, end, name, timeout, encoding) Executor.__init__(self, jail, end, name, timeout, encoding)
self.command = "{} -N {} -P {}".format(command, self.group.ID, if long_opt :
self.group.server_number) self.command = "{} --NETWORK={} --PORT={}".format(command,
self.group.ID,
self.group.server_number)
else :
self.command = "{} -N {} -P {}".format(command, self.group.ID,
self.group.server_number)
def run(self) : def run(self) :
self.framework.exec_on("0", self.framework.exec_on("0",
......
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment