Test fixes

Signed-off-by: Eric Kerfoot <17726042+ericspod@users.noreply.github.com>

Author: ericspod

.github/workflows/cicd_tests.yml

@@ -37,7 +37,7 @@ env:
   PYTORCH_VER2: '2.9.1'
   PYTORCH_VER3: '2.10.0'
   PYTORCH_VER4: '2.11.0'
-  TORCHVISION_VER: '0.23.0'  # used for testing with lowest PyTorch version
+  TORCHVISION_VER: '0.23.0'  # used for testing with lowest PyTorch version (PYTORCH_VER1), update as needed
   PROTOCOL_BUFFERS_PYTHON_IMPLEMENTATION: python  # https://github.com/Project-MONAI/MONAI/issues/4354
 
 # These jobs run the CICD tests, type checking, and testing packaging. These use the minimum supported versions of
@@ -98,7 +98,7 @@ jobs:
           pytorch-version: '2.8.0'
           python-version: '3.13'
         - os: ubuntu-latest
-          pytorch-version: '2.9.0'
+          pytorch-version: '2.9.1'
           python-version: '3.14'
 
         # Test PyTorch versions under Ubuntu with lowest Python version supported

tests/test_utils.py

@@ -533,7 +533,7 @@ def run_process(self, func, local_rank, args, kwargs, results):
                 time.sleep(0.1)
             results.put(True)
         except Exception as e:
-            results.put(False)
+            results.put(str(e))
             raise e
         finally:
             os.environ.clear()
@@ -562,15 +562,17 @@ def _wrapper(*args, **kwargs):
             results = tmp.Queue()
             func = _call_original_func
             args = [obj.__name__, obj.__module__] + list(args)
+
             for proc_rank in range(self.nproc_per_node):
-                p = tmp.Process(
-                    target=self.run_process, args=(func, proc_rank, args, kwargs, results), daemon=self.daemon
-                )
+                run_args = (func, proc_rank, args, kwargs, results)
+                p = tmp.Process(target=self.run_process, args=run_args, daemon=self.daemon)
                 p.start()
                 processes.append(p)
+
             for p in processes:
                 p.join()
-                assert results.get(), "Distributed call failed."
+                pr=results.get()
+                assert pr is True, f"Distributed call failed: {pr}"
             _del_original_func(obj)
 
         return _wrapper