diff --git a/micro_manager/adaptivity/global_adaptivity.py b/micro_manager/adaptivity/global_adaptivity.py index 35be5995..88a48641 100644 --- a/micro_manager/adaptivity/global_adaptivity.py +++ b/micro_manager/adaptivity/global_adaptivity.py @@ -312,7 +312,8 @@ def _p2p_comm(self, assoc_active_ids: list, data: list) -> list: recv_reqs = [] for global_id, recv_rank in recv_map.items(): tag = self._create_tag(global_id, recv_rank, self._rank) - req = self._comm.irecv(source=recv_rank, tag=tag) + bufsize = 1 << 30 # allocate and use a temporary 1 MiB buffer size https://github.com/mpi4py/mpi4py/issues/389 + req = self._comm.irecv(bufsize, source=recv_rank, tag=tag) recv_reqs.append(req) # Wait for all non-blocking communication to complete diff --git a/micro_manager/config.py b/micro_manager/config.py index 79164181..d881c09e 100644 --- a/micro_manager/config.py +++ b/micro_manager/config.py @@ -116,8 +116,6 @@ def read_json(self, config_filename): self._adaptivity_type = "local" elif data["simulation_params"]["adaptivity"]["type"] == "global": self._adaptivity_type = "global" - self._logger.warning( - "Global adaptivity is still experimental. We recommend using it for small (<50 macro vertices) cases only.") else: raise Exception("Adaptivity type can be either local or global.")