def __find_oldest_shard()

in datahub/client/consumer/offset_select_strategy.py [0:0]

• 12 lines of code
• 6 McCabe index (conditional complexity)

    def __find_oldest_shard(self):
        if len(self._offset_map) == 0:
            return None
        oldest_timestamp = -1
        oldest_shard_id = None
        for shard_id, timestamp in self._offset_map.items():
            if shard_id in self._empty_shards:
                continue
            if oldest_shard_id is None or timestamp < oldest_timestamp:
                oldest_timestamp = timestamp
                oldest_shard_id = shard_id
        return oldest_shard_id