diff --git a/startdb.py b/startdb.py index 1ef461d..eeea280 100644 --- a/startdb.py +++ b/startdb.py @@ -213,6 +213,16 @@ async def daily_cleanup_at( ) cleanup_logger.info(f"Deleted {result.rowcount} rows from Traceroute") + # ------------------------- + # NodePublicKey + # ------------------------- + result = await session.execute( + delete(models.NodePublicKey).where( + models.NodePublicKey.last_seen_us < cutoff_us + ) + ) + cleanup_logger.info(f"Deleted {result.rowcount} rows from NodePublicKey") + # ------------------------- # Node # -------------------------