def is_paused(self, partition):
        return partition in self.assignment and self.assignment[partition].paused
dataset/ETHPy150Open dpkp/kafka-python/kafka/consumer/subscription_state.py/SubscriptionState.is_paused/original