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