Fix indentation and aggregate past bucket, delete old aggregates

buzzkillb · buzzkillb · commit 7739c76adce7 · 2026-04-24T12:37:34.000-07:00
diff --git a/database.py b/database.py
@@ -116,7 +116,7 @@ async def _aggregate_prices(self):
             (ONE_WEEK, 5 * 365 * ONE_DAY),  # weekly for 5 years
         ]
 
-async with self.pool.acquire() as conn:
+        async with self.pool.acquire() as conn:
             for duration, max_age in buckets:
                 now = int(time.time())
                 bucket_start = (now // duration) * duration - duration

Original file line number	Diff line number	Diff line change
`@@ -116,7 +116,7 @@ async def _aggregate_prices(self):`
`116`	`116`	`(ONE_WEEK, 5 * 365 * ONE_DAY), # weekly for 5 years`
`117`	`117`	`]`
`118`	`118`
`119`		`-async with self.pool.acquire() as conn:`
	`119`	`+ async with self.pool.acquire() as conn:`
`120`	`120`	`for duration, max_age in buckets:`
`121`	`121`	`now = int(time.time())`
`122`	`122`	`bucket_start = (now // duration) * duration - duration`