fix: correct output

pyproject.toml

@@ -145,34 +145,33 @@ commands = [
     "coverage",
     "erase",
   ],
-#  [
-#    "coverage",
-#    "run",
-#    "--parallel-mode",
-#    "-m",
-#    "pytest",
-#    "{posargs}",
-#  ],
-#  [
-#    "coverage",
-#    "combine",
-#  ],
-#  [
-#    "coverage",
-#    "report",
-#  ],
+  [
+    "coverage",
+    "run",
+    "--parallel-mode",
+    "-m",
+    "pytest",
+    "{posargs}",
+  ],
+  [
+    "coverage",
+    "combine",
+  ],
+  [
+    "coverage",
+    "report",
+ ],
 ]
 
 [tool.coverage.run]
 source = [
-  "pkg1",
-  "shared_utils"
+  "src"
 ]
 parallel = true
 
 [tool.coverage.report]
 show_missing = false
-fail_under = 50
+fail_under = 0
 
 [tool.vulture]
 exclude = [

src/mpyflow/library/worker.py

@@ -237,6 +237,8 @@ async def __write(self, erg: OT, wpl: list[int], writer_len: int, /) -> None:
                 await self.__write_to_all(erg, writer_len)
             else:
                 await self.__write_to_one(erg, wpl, writer_len)
+        else:
+            self.evq.worker_queue.task_done()
 
     async def __writer(self, p_name: str, /) -> int:
         counter_write = 0

src/mpyflow/shared/logger/manager.py

@@ -251,18 +251,18 @@ def _print_status(manager: LogManager, /) -> str:
 
 
 def _p2c(manager: LogManager, message: SyncOutMsg, console: Console, /) -> None:
+    _check_message(message)
     with manager.manager_lock:
-        _check_message(message)
         new_act_object = manager.sync_object_manager.managed_dict.get(message.s_id, None)
         if new_act_object is not None:
             _check_object_status(message, new_act_object)
         new_act_object = (message.status, message.done)
         if message.done:
             manager.manager_done_counter.value += 1
         manager.sync_object_manager.managed_dict[message.s_id] = new_act_object
-        if len(message.msg) > 5:
-            console.log(message.msg)
-            time.sleep(1)
+    if len(message.msg) > 5:
+        console.log(message.msg)
+        time.sleep(1)
 
 
 def _waiting_output_str(manager: LogManager, /) -> None: