源码位置：dify/api/models/task.py

CeleryTask 表结构

字段英文名	数据类型	字段中文名字	备注
id	Integer	ID	自增主键，任务ID序列
task_id	String	任务ID	唯一任务标识
status	String	状态	默认值为 PENDING
result	PickleType	结果	可为空
date_done	DateTime	完成日期	默认当前时间，更新时间
traceback	Text	回溯	可为空
name	String	名称	可为空
args	LargeBinary	参数	可为空
kwargs	LargeBinary	关键字参数	可为空
worker	String	工作者	可为空
retries	Integer	重试次数	可为空
queue	String	队列	可为空

该表 celery_taskmeta 用于记录 Celery 任务的结果和状态。具体字段如下：

• id: 自增主键，唯一标识任务记录。

• task_id: 任务的唯一标识符。

• status: 任务状态，默认值为 PENDING。

• result: 任务结果，使用 PickleType 存储。

• date_done: 任务完成时间，默认当前 UTC 时间，更新时也会记录当前 UTC 时间。

• traceback: 任务出错时的回溯信息。

• name: 任务名称。

• args: 任务的参数，以二进制形式存储。

• kwargs: 任务的关键字参数，以二进制形式存储。

• worker: 执行任务的工人。

• retries: 任务重试次数。

• queue: 任务所在的队列。

CeleryTaskSet 表结构

字段英文名	数据类型	字段中文名字	备注
id	Integer	ID	自增主键，任务集ID序列
taskset_id	String	任务集ID	唯一任务集标识
result	PickleType	结果	可为空
date_done	DateTime	完成日期	默认当前时间

该表 celery_tasksetmeta 用于记录 Celery 任务集的结果。具体字段如下：

• id: 自增主键，唯一标识任务集记录。

• taskset_id: 任务集的唯一标识符。

• result: 任务集结果，使用 PickleType 存储。

• date_done: 任务集完成时间，默认当前 UTC 时间。

这些表用于管理和跟踪 Celery 异步任务的执行状态和结果。