async def on_closing_async(self, reason):
        """
        Overides partition pump on closing.

        :param reason: The reason for the shutdown.
        :type reason: str
        """
        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()
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 : _logger . info ( "Error on closing partition pump: %r" , err ) await self . clean_up_clients_async ( )
Overides partition pump on closing.

        :param reason: The reason for the shutdown.
        :type reason: str