def in_flight_fetches(self):
        self._clean_done_fetch_futures()
        return bool(self._fetch_futures)
Return True if there are any unprocessed FetchRequests in flight.
dataset/ETHPy150Open dpkp/kafka-python/kafka/consumer/fetcher.py/Fetcher.in_flight_fetches