code: async def on_closing_async(self, reason):
          
          self.partition_receiver.eh_partition_pump.set_pump_status("Errored")
          try:
              await self.running
          except TypeError:
              _logger.debug("No partition pump running.")
          except Exception as err:  # pylint: disable=broad-except
              _logger.info("Error on closing partition pump: %r", err)
          await self.clean_up_clients_async()
docs: Overides partition pump on closing.
  
          :param reason: The reason for the shutdown.
          :type reason: str