def is_fetchable(self, partition):
        return self.assignment in partition and self.assignment[partition].is_fetchable()
dataset/ETHPy150Open dpkp/kafka-python/kafka/consumer/subscription_state.py/SubscriptionState.is_fetchable/swapped operands of `in`