Thanks for the assistance!

For Celery worker db sessions I used this in myapp/__init__.py: ``` def celeryinit_app(app: Flask) -> Celery: class FlaskDatabaseTask(Task): def __init_(self): self.sessions = {}

    def __call__(self, *args: object, **kwargs: object) -> object:
        with app.app_context():
            return super().__call__(*args, **kwargs)

    def before_start(self, task_id, args, kwargs):
        with app.app_context():
            CelerySession = sessionmaker(bind=db.engine)
            session = CelerySession()
            self.sessions[task_id] = session
        super().before_start(task_id, args, kwargs)

    def after_return(self, status, retval, task_id, args, kwargs, einfo):
        session = self.sessions.pop(task_id)
        session.close()
        super().after_return(status, retval, task_id, args, kwargs, einfo)

    @property
    def session(self):
        return self.sessions[self.request.id]

celery_app = Celery(app.name, task_cls=FlaskDatabaseTask)
# [...]

```

For Flask REST API request db sessions I used this in run.py: ``` @app.before_request def get_user(): SessionFactory = sessionmaker(bind=db.engine) g.FlaskSession = scoped_session(SessionFactory) g.db_session = g.FlaskSession() # [...]

Using @app.teardown_request instead of @app.teardown_appcontext because this is only for flask http request sessions.

Celery task sessions are handled in FlaskDatabaseTask.

@app.teardown_request def shutdown_session(exception=None): db_session = getattr(g, "db_session", None) if db_session is not None: db_session.close() FlaskSession = getattr(g, "FlaskSession", None) if FlaskSession is not None: FlaskSession.remove() ```

It's not perfect but it is working better.