We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
2 parents 1b783d3 + b1e0ce9 commit 2b31f2eCopy full SHA for 2b31f2e
2 files changed
pympipool/parallel_executors/mpiexec.py
@@ -1,3 +1,4 @@
1
+from os.path import abspath
2
import pickle
3
import sys
4
@@ -33,6 +34,11 @@ def main():
33
34
socket = None
35
36
memory = None
37
+
38
+ cwd = abspath(".")
39
+ if cwd not in sys.path:
40
+ sys.path.insert(1, cwd)
41
42
while True:
43
# Read from socket
44
if mpi_rank_zero:
pympipool/parallel_executors/mpipool.py
@@ -27,6 +28,11 @@ def main():
27
28
29
future_dict = {}
30
argument_dict = parse_arguments(argument_lst=sys.argv)
31
32
with MPIPoolExecutor(int(argument_dict["total_cores"])) as executor:
if executor is not None:
context, socket = connect_to_socket_interface(
0 commit comments