From 215607c010f700b99473caf949714bfd30a5ab2e Mon Sep 17 00:00:00 2001 From: Adalberto Date: Fri, 17 Apr 2026 12:14:43 +0200 Subject: [PATCH] Added timeout --- pysemtools/io/adios2/stream.py | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/pysemtools/io/adios2/stream.py b/pysemtools/io/adios2/stream.py index 255db58..50b56ad 100644 --- a/pysemtools/io/adios2/stream.py +++ b/pysemtools/io/adios2/stream.py @@ -63,7 +63,7 @@ class DataStreamer: >>> ds.stream(x.reshape(x.size)) """ - def __init__(self, comm, from_nek=True): + def __init__(self, comm, from_nek=True, timeout_seconds = 300): # Adios status self.okstep = adios2.StepStatus.OK @@ -74,6 +74,8 @@ def __init__(self, comm, from_nek=True): # ADIOS IO - Engine self.io_asynchronous = self.adios.DeclareIO("streamIO") self.io_asynchronous.SetEngine("SST") + self.io_asynchronous.SetParameters({"OpenTimeoutSecs": str(timeout_seconds)}) + # Open the streams self.reader_st = self.io_asynchronous.Open(