I/O: worker argument has to be optional in read methods

Author: PierreRaybaut

cdl/core/io/base.py

@@ -257,7 +257,9 @@ def get_filter(self, action: IOAction) -> str:
             return ""
         return f"{self.info.name} ({self.info.extensions})"
 
-    def read(self, filename: str, worker: CallbackWorker) -> list[BaseObj]:
+    def read(
+        self, filename: str, worker: CallbackWorker | None = None
+    ) -> list[BaseObj]:
         """Read list of native objects (signal or image) from file.
         For single object, return a list with one object.
 

cdl/core/io/image/base.py

@@ -48,7 +48,9 @@ def create_object(filename: str, index: int | None = None) -> ImageObj:
             name += f" {index:02d}"
         return create_image(name)
 
-    def read(self, filename: str, worker: CallbackWorker) -> list[ImageObj]:
+    def read(
+        self, filename: str, worker: CallbackWorker | None = None
+    ) -> list[ImageObj]:
         """Read list of image objects from file
 
         Args:

cdl/core/io/image/formats.py

@@ -156,7 +156,9 @@ class AndorSIFImageFormat(ImageFormatBase):
         writeable=False,
     )
 
-    def read(self, filename: str, worker: CallbackWorker) -> list[ImageObj]:
+    def read(
+        self, filename: str, worker: CallbackWorker | None = None
+    ) -> list[ImageObj]:
         """Read list of image objects from file
 
         Args:
@@ -173,9 +175,10 @@ def read(self, filename: str, worker: CallbackWorker) -> list[ImageObj]:
                 obj = self.create_object(filename, index=idx)
                 obj.data = data[idx, ::]
                 objlist.append(obj)
-                worker.set_progress((idx + 1) / data.shape[0])
-                if worker.was_canceled():
-                    break
+                if worker is not None:
+                    worker.set_progress((idx + 1) / data.shape[0])
+                    if worker.was_canceled():
+                        break
             return objlist
         obj = self.create_object(filename)
         obj.data = data

cdl/core/io/signal/base.py

@@ -81,7 +81,9 @@ def create_signals_from(self, xydata: np.ndarray, filename: str) -> list[SignalO
             objs.append(obj)
         return objs
 
-    def read(self, filename: str, worker: CallbackWorker) -> list[SignalObj]:
+    def read(
+        self, filename: str, worker: CallbackWorker | None = None
+    ) -> list[SignalObj]:
         """Read list of signal objects from file
 
         Args:

cdl/core/io/signal/formats.py

@@ -31,7 +31,9 @@ class CSVSignalFormat(SignalFormatBase):
         writeable=True,
     )
 
-    def read(self, filename: str, worker: CallbackWorker) -> list[SignalObj]:
+    def read(
+        self, filename: str, worker: CallbackWorker | None = None
+    ) -> list[SignalObj]:
         """Read list of signal objects from file
 
         Args:

cdl/core/io/signal/funcs.py

@@ -107,7 +107,7 @@ def read_csv_by_chunks(
 
 def read_csv(
     filename: str,
-    worker: CallbackWorker,
+    worker: CallbackWorker | None = None,
 ) -> tuple[
     np.ndarray, str | None, str | None, list[str] | None, list[str] | None, str | None
 ]: