'Get the exceptions raised by the consumers that do not return any
data under normal circumstances, for example: grep and auth and handle
them properly.'

def _handle_all_consumer_exceptions(self, _other):

    for other_consumer in _other:
        try:
            result_item = other_consumer.get_result(timeout=0.2)
        except TimeoutError:
            pass
        except Queue.Empty:
            pass
        else:
            if isinstance(result_item, ExceptionData):
                self._handle_consumer_exception(result_item)
