Update 1 code files

Modified:
  • src/omnipkg/common_utils.py (+9/-8 lines)

[gitship-generated]

Author: 1minds3t

src/omnipkg/common_utils.py

@@ -738,15 +738,16 @@ def is_interactive_session():
 def _worker_emit(obj: dict) -> None:
     """Write one JSON line to the real stdout pipe, bypassing StreamRedirector."""
     msg = json.dumps(obj, ensure_ascii=True) + "\n"
-    os.write(1, msg.encode("utf-8"))
+    try:
+        # Windows: stdout may be text-buffered, use buffer + explicit flush
+        sys.stdout.buffer.write(msg.encode("utf-8"))
+        sys.stdout.buffer.flush()
+    except AttributeError:
+        # Fallback for environments without buffer attribute
+        os.write(1, msg.encode("utf-8"))
 
 
 def _worker_read_reply() -> dict:
-    """Read one JSON line from worker stdin (the daemon reply channel).
-
-    The daemon writes to worker.process.stdin (also text mode) after
-    receiving the stdin_line from the C dispatcher.
-    """
     import threading
     result = [None]
     exc = [None]
@@ -759,9 +760,9 @@ def _read():
 
     t = threading.Thread(target=_read, daemon=True)
     t.start()
-    t.join(5.0)
+    t.join(10.0)  # bump to 10s for slow Windows pipes
     if t.is_alive():
-        raise TimeoutError("no stdin reply within 5s")
+        raise TimeoutError("no stdin reply within 10s")
     if exc[0]:
         raise exc[0]
     if not result[0]: