Stay with atproto==0.0.56 for now

firehose/health_check.py

@@ -4,11 +4,14 @@
 from database import db, SubscriptionState
 
 def is_healthy():
+    state = None
     with db.connection_context():
-        state = SubscriptionState.get_or_none()
-        if not state or not state.last_indexed_at:
-            return False
-        return (datetime.now(timezone.utc) - state.last_indexed_at) < timedelta(minutes=5)
+        with db.atomic():
+            state = SubscriptionState.get_or_none()
+
+    if not state or not state.last_indexed_at:
+        return False
+    return (datetime.now(timezone.utc) - state.last_indexed_at) < timedelta(minutes=5)
 
 if __name__ == "__main__":
     if is_healthy():

firehose/requirements.txt

@@ -1,4 +1,4 @@
 psycopg2-binary
-atproto
+atproto==0.0.56
 peewee
 python-dotenv

requirements.txt

@@ -1,4 +1,4 @@
-atproto
+atproto==0.0.56
 peewee
 Flask
 python-dotenv

scheduler/requirements.txt

@@ -1,4 +1,4 @@
-atproto
+atproto==0.0.56
 apscheduler
 peewee
 psycopg2-binary