Method flush

astrbot/core/utils/metrics.py:175–184

Flush pending metrics immediately.

()

    @staticmethod
    async def flush() -> None:
        """Flush pending metrics immediately."""
        lock = Metric._get_lock()
        async with lock:
            pending_metrics = list(Metric._pending_metrics.values())
            Metric._pending_metrics = {}

        for metrics_data in pending_metrics:
            await Metric._post_metrics(metrics_data)
            await asyncio.sleep(0.25)

    @staticmethod
    async def _post_metrics(metrics_data: dict[str, Any]) -> None: