Coverage for baibu/metrics/tasks.py: 100%

1from celery import shared_task 

2 

3from . import rollups 

4 

5 

6@shared_task(ignore_result=True) 

7def compute_daily_metrics() -> dict: 

8 """Nightly: compute yesterday's rollups, and any earlier days the worker missed.""" 

9 first, last = rollups.days_to_catch_up() 

10 days = rollups.store_range(first, last) 

11 return {"first": first.isoformat(), "last": last.isoformat(), "days": days}