class ContextTask(TaskBase):
    abstract = True

def __call__(self, *args, **kwargs):
    return TaskBase.__call__(self, *args, **kwargs)
Соединение закрывается, когда событие SQLAlchemy запускает задачу Celery.