@event.listens_for(User, 'after_delete')
def after_delete(mapper, connection, target):
    my_task.delay(target.value)

@celery.task()
def my_task(image_path):
    os.remove(image_path)
Соединение закрывается, когда событие SQLAlchemy запускает задачу Celery.