async def stop_async(self):
        """
        Terminiates the partition manger.
        """
        self.cancellation_token.cancel()
        if self.run_task and not self.run_task.done():
            await self.run_task