🤖 Implement Singleton Initialization for Celery App and Database

src/celery_app/app.py

@@ -19,13 +19,20 @@ def setup_celery_entrypoint(app: Celery):
     app.on_configure.connect(init_celery_app)
 
 
+# Track if bootup has been performed
+_bootup_complete = False
+
 @inject
 def init_celery_app(*args: Any, sender: Celery, config: CeleryConfig = injected, **kwargs: Any):
+    global _bootup_complete
     for k, v in config.items():
         setattr(sender.conf, k, v)
-    bootup(start_model_loading=False, integrations=[CeleryIntegration(propagate_traces=True)])
+
+    if not _bootup_complete:
+        bootup(start_model_loading=False, integrations=[CeleryIntegration(propagate_traces=True)])
+        _bootup_complete = True
+
     from celery_app.tasks import setup_periodic_tasks
-
     sender.on_after_finalize.connect(setup_periodic_tasks)
 
 

src/seer/db.py

@@ -35,20 +35,31 @@
 from seer.configuration import AppConfig
 from seer.dependency_injection import inject, injected
 
+# Module-level flag to track initialization state
+_db_initialized = False
 
 @inject
 def initialize_database(
     config: AppConfig = injected,
     app: Flask = injected,
 ):
-    app.config["SQLALCHEMY_DATABASE_URI"] = config.DATABASE_URL
-    app.config["SQLALCHEMY_ENGINE_OPTIONS"] = {"connect_args": {"prepare_threshold": None}}
+    global _db_initialized
+    if _db_initialized:
+        return
+
+    try:
+        app.config["SQLALCHEMY_DATABASE_URI"] = config.DATABASE_URL
+        app.config["SQLALCHEMY_ENGINE_OPTIONS"] = {"connect_args": {"prepare_threshold": None}}
+
 
     db.init_app(app)
     migrate.init_app(app, db)
 
+
     with app.app_context():
         Session.configure(bind=db.engine)
+
+    _db_initialized = True
 
 
 class Base(DeclarativeBase):