diff --git a/.ci_support/environment-mpich.yml b/.ci_support/environment-mpich.yml index 8779fb31..20aa1dd5 100644 --- a/.ci_support/environment-mpich.yml +++ b/.ci_support/environment-mpich.yml @@ -8,4 +8,4 @@ dependencies: - mpich - numpy =1.23.5 - mpi4py =3.1.4 - - pympipool =0.5.4 \ No newline at end of file + - pympipool =0.5.5 \ No newline at end of file diff --git a/.ci_support/environment-openmpi.yml b/.ci_support/environment-openmpi.yml index 7a494995..a55ca12d 100644 --- a/.ci_support/environment-openmpi.yml +++ b/.ci_support/environment-openmpi.yml @@ -8,4 +8,4 @@ dependencies: - openmpi - numpy =1.23.5 - mpi4py =3.1.4 - - pympipool =0.5.4 \ No newline at end of file + - pympipool =0.5.5 \ No newline at end of file diff --git a/binder/environment.yml b/binder/environment.yml index d3d4f6f3..75306b83 100644 --- a/binder/environment.yml +++ b/binder/environment.yml @@ -5,4 +5,4 @@ dependencies: - numpy =1.23.5 - lammps >=2021.05.27 - mpi4py =3.1.4 -- pympipool =0.5.3 +- pympipool =0.5.5 diff --git a/pylammpsmpi/wrapper/concurrent.py b/pylammpsmpi/wrapper/concurrent.py index 155166a4..fbaaec61 100644 --- a/pylammpsmpi/wrapper/concurrent.py +++ b/pylammpsmpi/wrapper/concurrent.py @@ -6,8 +6,7 @@ import socket from concurrent.futures import Future from queue import Queue -from threading import Thread -from pympipool import SocketInterface, cancel_items_in_queue +from pympipool import RaisingThread, SocketInterface, cancel_items_in_queue __author__ = "Sarath Menon, Jan Janssen" @@ -107,7 +106,7 @@ def __init__( self._queue_adapter_kwargs = queue_adapter_kwargs def start_process(self): - self._process = Thread( + self._process = RaisingThread( target=execute_async, kwargs={ "future_queue": self._future_queue, diff --git a/setup.py b/setup.py index 3196d0e8..88b92a50 100644 --- a/setup.py +++ b/setup.py @@ -26,7 +26,7 @@ keywords='lammps, mpi4py', packages=find_packages(exclude=["*tests*"]), install_requires=[ - "mpi4py==3.1.4", "pympipool==0.5.4", "numpy==1.23.5" + "mpi4py==3.1.4", "pympipool==0.5.5", "numpy==1.23.5" ], cmdclass=versioneer.get_cmdclass(), )