python - 在 Celery 任务中所做的数据库更改在主线程中不可见

Question

在Celery任务中更新或创建新对象时，在主线程中读取新数据失败。更新/创建后我发出

db.session.commit()

从 cmd 看来，数据库中的数据已更新，但可能 session 中的某些内容仍在获取旧数据。当我在同一个线程中更新一些对象时，它工作正常。

Answer 1

实际上我不确定为什么我们需要在 Celery 任务上使用 commit 命令来结束事务，然后再次在主线程上。下面是工作示例:

此 celery 任务每 7 秒运行一次。

@scheduler.task()
def run_task():
    task = Tasks.get_task("task1")
    task.update_task({'status': "succeed"})
    db.session.commit()


def test_update_task(self):
    task = create_task("task1", status="active")

    log.warning("task {} status before change:{}".format(task.id, task.status))

    time.sleep(10)

    # Here the celery task will update task status from "active" to "succeed"
    db.session.commit()
    log.warning("test {} task status after Celery change:{}".format(task.id, task.status))