Stops all partition pumps
        (Note this might be wrong and need to await all tasks before returning done).

        :param reason: A reason for closing.
        :type reason: str
        :rtype: bool

async def remove_all_pumps_async(self, reason):
        """
        Stops all partition pumps
        (Note this might be wrong and need to await all tasks before returning done).

        :param reason: A reason for closing.
        :type reason: str
        :rtype: bool
        """
        pump_tasks = [self.remove_pump_async(p_id, reason) for p_id in self.partition_pumps]
        await asyncio.gather(*pump_tasks)
        return True