Method seal_due

gpustack/schemas/metered_usage.py:208–234

Seal every still-open bucket whose hour has fully elapsed. A bucket ``[t, t+1h)`` is finalized once ``now >= t + 1h + grace``: the hour is over and the grace window has absorbed any late-arriving event, so nothing more can land in it. Run on the collector tick *after*

(
        cls,
        session,
        meter_key: str,
        now: datetime,
        grace_seconds: int,
    )

    @classmethod
    async def seal_due(
        cls,
        session,
        meter_key: str,
        now: datetime,
        grace_seconds: int,
    ) -> None:
        """Seal every still-open bucket whose hour has fully elapsed.

        A bucket ``[t, t+1h)`` is finalized once ``now >= t + 1h + grace``: the
        hour is over and the grace window has absorbed any late-arriving event,
        so nothing more can land in it. Run on the collector tick *after*
        settling, so a still-running resource's current hour is written before
        it becomes eligible. Idempotent — only NULL ``sealed_at`` rows of this
        meter are touched.
        """
        cutoff = now - timedelta(hours=1, seconds=grace_seconds)
        await session.exec(
            update(cls)
            .where(
                cls.meter_key == meter_key,
                cls.sealed_at.is_(None),
                cls.bucket_start <= cutoff,
            )
            .values(sealed_at=now)
        )
        await session.commit()


# ---------------------------------------------------------------------------