diff --git a/pkg/models/taskaimodel_gen.go b/pkg/models/taskaimodel_gen.go
index b8a9e627..ab0c5502 100644
--- a/pkg/models/taskaimodel_gen.go
+++ b/pkg/models/taskaimodel_gen.go
@@ -42,7 +42,7 @@ type (
 		ClusterId  int64     `db:"cluster_id"`  // 集群id
 		Name       string    `db:"name"`        // 任务名
 		Replica    int64     `db:"replica"`     // 执行数
-		CTaskId    string    `db:"c_task_id"`   // 集群返回任务id
+		JobId      string    `db:"job_id"`      // 集群返回任务id
 		Strategy   string    `db:"strategy"`    // 主任务使用策略
 		Status     string    `db:"status"`      // 任务状态
 		Msg        string    `db:"msg"`         // 集群返回任务信息
@@ -88,13 +88,13 @@ func (m *defaultTaskAiModel) FindOne(ctx context.Context, id int64) (*TaskAi, er
 
 func (m *defaultTaskAiModel) Insert(ctx context.Context, data *TaskAi) (sql.Result, error) {
 	query := fmt.Sprintf("insert into %s (%s) values (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)", m.table, taskAiRowsExpectAutoSet)
-	ret, err := m.conn.ExecCtx(ctx, query, data.TaskId, data.AdapterId, data.ClusterId, data.Name, data.Replica, data.CTaskId, data.Strategy, data.Status, data.Msg, data.CommitTime, data.StartTime, data.EndTime)
+	ret, err := m.conn.ExecCtx(ctx, query, data.TaskId, data.AdapterId, data.ClusterId, data.Name, data.Replica, data.JobId, data.Strategy, data.Status, data.Msg, data.CommitTime, data.StartTime, data.EndTime)
 	return ret, err
 }
 
 func (m *defaultTaskAiModel) Update(ctx context.Context, data *TaskAi) error {
 	query := fmt.Sprintf("update %s set %s where `id` = ?", m.table, taskAiRowsWithPlaceHolder)
-	_, err := m.conn.ExecCtx(ctx, query, data.TaskId, data.AdapterId, data.ClusterId, data.Name, data.Replica, data.CTaskId, data.Strategy, data.Status, data.Msg, data.CommitTime, data.StartTime, data.EndTime, data.Id)
+	_, err := m.conn.ExecCtx(ctx, query, data.TaskId, data.AdapterId, data.ClusterId, data.Name, data.Replica, data.JobId, data.Strategy, data.Status, data.Msg, data.CommitTime, data.StartTime, data.EndTime, data.Id)
 	return err
 }