WIP: Update collector for SQLAlchemy 2.0

TODO:
* Use bulk insert/update methods (optimize lookup query?)
* TEST!

meshinfo/collector.py

@@ -12,6 +12,7 @@
 
 import pendulum
 import structlog
+from sqlalchemy import sql
 from sqlalchemy.orm import Session
 from structlog.contextvars import bound_contextvars
 
@@ -247,29 +248,31 @@ def expire_data(
     if count is None:
         count = defaultdict(int)
     inactive_cutoff = timestamp.subtract(days=links_expire)
-    count["expired: links"] = (
-        dbsession.query(Link)
-        .filter(
+    stmt = (
+        sql.update(Link)
+        .where(
             Link.status == LinkStatus.RECENT,
             Link.last_seen < inactive_cutoff,
         )
-        .update({Link.status: LinkStatus.INACTIVE})
+        .values(status=LinkStatus.INACTIVE)
     )
+    count["expired: links"] = dbsession.execute(stmt).rowcount
     logger.info(
         "Marked inactive links",
         count=count["expired: links"],
         cutoff=inactive_cutoff,
     )
 
     inactive_cutoff = timestamp.subtract(days=nodes_expire)
-    count["expired: nodes"] = (
-        dbsession.query(Node)
-        .filter(
+    stmt = (
+        sql.update(Node)
+        .where(
             Node.status == NodeStatus.ACTIVE,
             Node.last_seen < inactive_cutoff,
         )
-        .update({Node.status: NodeStatus.INACTIVE})
+        .values(status=NodeStatus.INACTIVE)
     )
+    count["expired: nodes"] = dbsession.execute(stmt).rowcount
     logger.info(
         "Marked inactive nodes",
         count=count["expired: nodes"],