diff options
| author | Christian Cleberg <[email protected]> | 2026-04-11 17:39:21 -0500 |
|---|---|---|
| committer | Christian Cleberg <[email protected]> | 2026-04-11 17:39:21 -0500 |
| commit | e1a3233ec2204055faa8dadb18cb2efa12cf0e17 (patch) | |
| tree | fa6b70671c3f6b71a690e1c99f368616cb1a8e4d /src/srht_contrib/services/aggregator.py | |
| parent | aebe493dcd2b46bf3ae46543f2c0e81625d93ae5 (diff) | |
| download | hutch-stats-e1a3233ec2204055faa8dadb18cb2efa12cf0e17.tar.gz hutch-stats-e1a3233ec2204055faa8dadb18cb2efa12cf0e17.tar.bz2 hutch-stats-e1a3233ec2204055faa8dadb18cb2efa12cf0e17.zip | |
feat: add resumable historical backfill for actor activity
Diffstat (limited to 'src/srht_contrib/services/aggregator.py')
| -rw-r--r-- | src/srht_contrib/services/aggregator.py | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/src/srht_contrib/services/aggregator.py b/src/srht_contrib/services/aggregator.py index 90ef93b..1c8af86 100644 --- a/src/srht_contrib/services/aggregator.py +++ b/src/srht_contrib/services/aggregator.py @@ -81,6 +81,9 @@ class ContributionAggregator: is_indexed=is_indexed, last_polled_at=tracked_actor.last_polled_at if tracked_actor is not None else None, indexing_state=indexing_state, + is_backfilled=(tracked_actor.backfill_status == "completed") if tracked_actor is not None else False, + backfill_state=(tracked_actor.backfill_status if tracked_actor is not None else "pending"), + backfill_completed_at=tracked_actor.backfill_completed_at if tracked_actor is not None else None, ) def _query_daily_aggregates(self, db: Session, actor: str, start: date, end: date) -> list[DailyAggregate]: |