Merge pull request #11989 from bcoca/osx_queue_fix

changed check to avoid OS X broken sem_getvalue()
This commit is contained in:
Brian Coca
2015-08-18 09:58:21 -04:00

View File

@@ -72,7 +72,7 @@ class ResultProcess(multiprocessing.Process):
self._cur_worker = 0
try:
if rslt_q.qsize() > 0:
if not rslt_q.empty():
debug("worker %d has data to read" % self._cur_worker)
result = rslt_q.get()
debug("got a result from worker %d: %s" % (self._cur_worker, result))