'Return set of TopicPartitions that should be Fetched.'

def fetchable_partitions(self):

    fetchable = set()
    for (partition, state) in six.iteritems(self.assignment):
        if state.is_fetchable():
            fetchable.add(partition)
    return fetchable
