mercurial/worker.py

--- a/mercurial/worker.py	Wed Jun 01 03:12:23 2022 +0200
+++ b/mercurial/worker.py	Sun May 22 03:50:34 2022 +0200
@@ -250,8 +250,10 @@
                         os.close(r)
                         os.close(w)
                     os.close(rfd)
-                    for result in func(*(staticargs + (pargs,))):
-                        os.write(wfd, pickle.dumps(result))
+                    with os.fdopen(wfd, 'wb') as wf:
+                        for result in func(*(staticargs + (pargs,))):
+                            pickle.dump(result, wf)
+                            wf.flush()
                     return 0
 
                 ret = scmutil.callcatch(ui, workerfunc)