code: async def remove_all_pumps_async(self, reason):
          
          pump_tasks = [self.remove_pump_async(p_id, reason) for p_id in self.partition_pumps]
          await asyncio.gather(*pump_tasks)
          return True
docs: 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