1 files changed, 4 insertions, 5 deletions
diff --git a/bin/bitbake-worker b/bin/bitbake-worker
index ed266f0ac..a3ea5d961 100755
--- a/bin/bitbake-worker
+++ b/bin/bitbake-worker
@@ -121,11 +121,10 @@ def worker_child_fire(event, d):
 
     data = b"<event>" + pickle.dumps(event) + b"</event>"
     try:
-        worker_pipe_lock.acquire()
-        while(len(data)):
-            written = worker_pipe.write(data)
-            data = data[written:]
-        worker_pipe_lock.release()
+        with bb.utils.lock_timeout(worker_pipe_lock):
+            while(len(data)):
+                written = worker_pipe.write(data)
+                data = data[written:]
     except IOError:
         sigterm_handler(None, None)
         raise