rate_limiter.py

    async def close(self) -> None:
        if self.quota_consumer_task and not self.quota_consumer_task.cancelled():
            try:
                self.quota_consumer_task.cancel()
                await self.quota_consumer_task
            except asyncio.CancelledError:
                # ignore the error here but log to inform the task was cancelled
                pass
            except Exception as e:
                # log and deal with the error here
                pass