Catch BlockingIOError in job_server.

catkin_tools/execution/job_server.py

@@ -165,6 +165,8 @@ def _set_max_jobs(cls, max_jobs):
         except OSError as e:
             if e.errno != errno.EINTR:
                 raise
+        except BlockingIOError:
+            pass
 
         # Update max jobs
         cls._max_jobs = max_jobs
@@ -259,6 +261,8 @@ def _acquire(cls):
             # read a token from the job pipe
             token = os.read(cls._job_pipe[0], 1)
             return token
+        except BlockingIOError:
+            pass
         except OSError as e:
             if e.errno != errno.EINTR:
                 raise
@@ -279,9 +283,7 @@ def _running_jobs(cls):
             buf = array.array('i', [0])
             if fcntl.ioctl(cls._job_pipe[0], FIONREAD, buf) == 0:
                 return cls._max_jobs - buf[0]
-        except NotImplementedError:
-            pass
-        except OSError:
+        except (NotImplementedError, OSError, BlockingIOError):
             pass
 
         return cls._max_jobs