Async API

"""
Async pairs — every terminal has an `a*` sibling.

Same surface as query-basics, but using `aquery` and `acount` / `amean`.
Useful for fanning out multiple queries concurrently.
"""

import asyncio
from datetime import datetime, timedelta, timezone

from vectorshift import Analytics
from vectorshift.analytics import EventField


async def dashboard():
    """Fetch a 3-metric dashboard in parallel."""
    q = Analytics.aquery().where(
        EventField.EVENT_START_TIME > datetime.now(timezone.utc) - timedelta(days=7)
    )

    runs, failures, latency = await asyncio.gather(
        q.acount(),
        q.where(status="failure").acount(),
        q.amean("latency"),
    )

    print(f"runs:         {runs['count']}")
    print(f"failures:     {failures['count']}")
    print(f"mean latency: {latency:.2f} ms")


async def main():
    await dashboard()
    print("Done.")


if __name__ == "__main__":
    asyncio.run(main())

runs:         ...
failures:     ...
mean latency: ... ms
Done.