Merge pull request #236 from delira-dev/fixed_logging

Fixed logging

Author: ORippler

delira/logging/base_backend.py

@@ -151,7 +151,7 @@ def _log_item(self):
 
         """
         # get item from dict
-        process_item = self._queue.get(timeout=0.5)
+        process_item = self._queue.get(timeout=0.001)
         # log item if item is dict
         if isinstance(process_item, dict):
 

delira/logging/base_logger.py

@@ -1,5 +1,6 @@
-from multiprocessing import Queue, Event
-from queue import Full
+from multiprocessing.queues import Queue as MpQueue
+from threading import Event
+from queue import Queue, Full
 from delira.logging.base_backend import BaseBackend
 from delira.utils.dict_reductions import get_reduction, possible_reductions, \
     reduce_dict
@@ -231,8 +232,9 @@ def close(self):
 
         """
         if hasattr(self, "_flush_queue"):
-            self._flush_queue.close()
-            self._flush_queue.join_thread()
+            if isinstance(self._flush_queue, MpQueue):
+                self._flush_queue.close()
+                self._flush_queue.join_thread()
 
         if hasattr(self, "abort_event"):
             self._abort_event.set()

delira/utils/dict_reductions.py

@@ -205,7 +205,11 @@ def reduce_dict(items: list, reduce_fn) -> dict:
 
     for k, v in result_dict.items():
         # check if all items are equal
-        if all([_v == v[0] for _v in v[1:]]):
+        equals = [_v == v[0] for _v in v[1:]]
+        for idx, equality in enumerate(equals):
+            if isinstance(equality, np.ndarray):
+                equals[idx] = equality.all()
+        if all(equals):
             # use first item since they are equal
             result_dict[k] = v[0]
         else: