task reason 改为 error

memory-overflow · memory-overflow · commit 0d3016f0f772 · 2025-08-21T14:26:50.000+08:00
diff --git a/actuator/function_actuator.go b/actuator/function_actuator.go
@@ -121,7 +121,7 @@ func (fc *fucntionActuator) Start(ctx context.Context, ftask *framework.Task) (
 			callbackTask.TaskStatus = newStatus.TaskStatus
 			callbackTask.TaskEnbTime = time.Now()
 			if newStatus.FailedReason != nil {
-				callbackTask.FailedReason = newStatus.FailedReason.Error()
+				callbackTask.FailedReason = newStatus.FailedReason
 			}
 			fc.callbackChannel <- callbackTask
 		}
diff --git a/container/memory_container/queue_container.go b/container/memory_container/queue_container.go
@@ -140,7 +140,7 @@ func (q *queueContainer) ToFailedStatus(ctx context.Context, task *lighttasksche
 		atomic.AddInt32(&q.runningTaskCount, -1)
 	}
 	task.TaskStatus = lighttaskscheduler.TASK_STATUS_FAILED
-	task.FailedReason = reason.Error()
+	task.FailedReason = reason
 	return task, nil
 }
 
diff --git a/example/videocut_example/video_cut/example_sql_container.go b/example/videocut_example/video_cut/example_sql_container.go
@@ -261,7 +261,7 @@ func (e *videoCutSqlContainer) ToFailedStatus(ctx context.Context, ftask *framew
 		return ftask, fmt.Errorf("task %s not found, may status has been changed", task.TaskId)
 	}
 	task.Status, ftask.TaskStatus = framework.TASK_STATUS_FAILED, framework.TASK_STATUS_FAILED
-	task.FailedReason, ftask.FailedReason = reason.Error(), reason.Error()
+	task.FailedReason, ftask.FailedReason = reason.Error(), reason
 	task.EndAt, ftask.TaskEnbTime = &t, t
 	ftask.TaskItem = task
 	return ftask, nil
diff --git a/task.go b/task.go
@@ -31,7 +31,7 @@ type Task struct {
 	// 任务状态，任务容器负责赋予值
 	TaskStatus TaskStatus
 	// 任务容器负责赋予值
-	FailedReason string
+	FailedReason error
 	// 任务已经重试的次数，任务容器负责赋予值
 	TaskAttemptsTime int32
 }
diff --git a/task_scheduler.go b/task_scheduler.go
@@ -2,7 +2,6 @@ package lighttaskscheduler
 
 import (
 	"context"
-	"errors"
 	"fmt"
 	"log"
 	"runtime/debug"
@@ -374,7 +373,7 @@ func (s *TaskScheduler) updateCallbackTask() {
 						}
 					}
 				} else {
-					s.failed(s.ctx, &task, errors.New(task.FailedReason))
+					s.failed(s.ctx, &task, task.FailedReason)
 				}
 			} else if task.TaskStatus == TASK_STATUS_SUCCESS {
 				s.export(s.ctx, &task)

Original file line number	Diff line number	Diff line change
`@@ -121,7 +121,7 @@ func (fc fucntionActuator) Start(ctx context.Context, ftask framework.Task) (`
`121`	`121`	`callbackTask.TaskStatus = newStatus.TaskStatus`
`122`	`122`	`callbackTask.TaskEnbTime = time.Now()`
`123`	`123`	`if newStatus.FailedReason != nil {`
`124`		`- callbackTask.FailedReason = newStatus.FailedReason.Error()`
	`124`	`+ callbackTask.FailedReason = newStatus.FailedReason`
`125`	`125`	`}`
`126`	`126`	`fc.callbackChannel <- callbackTask`
`127`	`127`	`}`
Original file line number	Diff line number	Diff line change
`@@ -140,7 +140,7 @@ func (q queueContainer) ToFailedStatus(ctx context.Context, task lighttasksche`
`140`	`140`	`atomic.AddInt32(&q.runningTaskCount, -1)`
`141`	`141`	`}`
`142`	`142`	`task.TaskStatus = lighttaskscheduler.TASK_STATUS_FAILED`
`143`		`- task.FailedReason = reason.Error()`
	`143`	`+ task.FailedReason = reason`
`144`	`144`	`return task, nil`
`145`	`145`	`}`
`146`	`146`
Original file line number	Diff line number	Diff line change
`@@ -261,7 +261,7 @@ func (e videoCutSqlContainer) ToFailedStatus(ctx context.Context, ftask framew`
`261`	`261`	`return ftask, fmt.Errorf("task %s not found, may status has been changed", task.TaskId)`
`262`	`262`	`}`
`263`	`263`	`task.Status, ftask.TaskStatus = framework.TASK_STATUS_FAILED, framework.TASK_STATUS_FAILED`
`264`		`- task.FailedReason, ftask.FailedReason = reason.Error(), reason.Error()`
	`264`	`+ task.FailedReason, ftask.FailedReason = reason.Error(), reason`
`265`	`265`	`task.EndAt, ftask.TaskEnbTime = &t, t`
`266`	`266`	`ftask.TaskItem = task`
`267`	`267`	`return ftask, nil`
Original file line number	Diff line number	Diff line change
`@@ -31,7 +31,7 @@ type Task struct {`
`31`	`31`	`// 任务状态，任务容器负责赋予值`
`32`	`32`	`TaskStatus TaskStatus`
`33`	`33`	`// 任务容器负责赋予值`
`34`		`- FailedReason string`
	`34`	`+ FailedReason error`
`35`	`35`	`// 任务已经重试的次数，任务容器负责赋予值`
`36`	`36`	`TaskAttemptsTime int32`
`37`	`37`	`}`
Original file line number	Diff line number	Diff line change
`@@ -2,7 +2,6 @@ package lighttaskscheduler`
`2`	`2`
`3`	`3`	`import (`
`4`	`4`	`"context"`
`5`		`- "errors"`
`6`	`5`	`"fmt"`
`7`	`6`	`"log"`
`8`	`7`	`"runtime/debug"`
`@@ -374,7 +373,7 @@ func (s *TaskScheduler) updateCallbackTask() {`
`374`	`373`	`}`
`375`	`374`	`}`
`376`	`375`	`} else {`
`377`		`- s.failed(s.ctx, &task, errors.New(task.FailedReason))`
	`376`	`+ s.failed(s.ctx, &task, task.FailedReason)`
`378`	`377`	`}`
`379`	`378`	`} else if task.TaskStatus == TASK_STATUS_SUCCESS {`
`380`	`379`	`s.export(s.ctx, &task)`