Switch to a cross-worker redis cache for accessy caches. Switch back to sync workers to avoid db deadlocks.

Author: HalfVoxel

api/requirements.txt

@@ -3,11 +3,11 @@ flask
 flask_cors
 sqlalchemy~=2.0.0
 gunicorn
-gunicorn[gevent]
 cryptography
 rocky>=1,<2
 PyMySQL
 requests
+redis
 python-dotenv
 bcrypt
 stripe==7.8.2
@@ -22,6 +22,7 @@ types-python-dateutil
 types-requests
 types-markdown
 types-PyMySQL
+types-redis
 markdown
 NamedAtomicLock
 dataclasses_json

api/run.sh

@@ -18,4 +18,4 @@ fi
 echo "initializing and migrating db"
 python3 ./init_db.py
 
-exec gunicorn ${GUNICORN_FLAGS} --access-logfile - --log-level info --error-logfile - --worker-class gevent --workers=${GUNICORN_WORKERS} -b :80 api:app
+exec gunicorn ${GUNICORN_FLAGS} --access-logfile - --log-level info --error-logfile - --worker-class sync --workers=${GUNICORN_WORKERS} -b :80 api:app

api/src/accessy_syncer.py

@@ -7,6 +7,7 @@
 from typing import Any
 
 import schedule
+from multiaccessy.accessy import accessy_session
 from multiaccessy.sync import sync
 from rocky.process import log_exception, stoppable
 from service.config import get_mysql_config
@@ -60,6 +61,13 @@ def daily_job() -> None:
     scheduled_sync()
 
 
+def hourly_job() -> None:
+    if accessy_session is not None:
+        # Refresh the pending invitations cache regularly to avoid slowing down
+        # any user-facing pages that rely on it
+        accessy_session.refresh_pending_invitations()
+
+
 def main() -> None:
     with log_exception(status=1), stoppable():
         parser = ArgumentParser(
@@ -91,6 +99,7 @@ def main() -> None:
 
             case x if x == COMMAND_SCHEDULED:
                 schedule.every().day.at("04:00").do(daily_job)
+                schedule.every().hour.do(hourly_job)
 
                 while not exit.is_set():
                     schedule.run_pending()