#### Version 0.9.8

* feature: TaskContext增加Header属性,类型为Map[string]interface{},用于在一次执行周期内传递自定义数据，每次执行完置空
* feature: TaskContext增加Error属性,类型为error,用于在一次执行周期内传递执行结果的Error信息，每次执行完置空
* 2020-03-28 16:00 at ShangHai

Author: devfeel

crontask.go

@@ -156,7 +156,8 @@ func startCronTask(task *CronTask) {
 
 func doCronTask(task *CronTask) {
 	defer func() {
-		task.context.Header = nil
+		task.Context().Header = nil
+		task.Context().Error = nil
 		if err := recover(); err != nil {
 			task.CounterInfo().ErrorCounter.Inc(1)
 			task.taskService.Logger().Debug(fmt.Sprint(task.TaskID, " cron handler recover error => ", err))
@@ -188,6 +189,7 @@ func doCronTask(task *CronTask) {
 			err = task.handler(task.Context())
 		}
 		if err != nil {
+			task.Context().Error = err
 			task.CounterInfo().ErrorCounter.Inc(1)
 			if task.taskService != nil && task.taskService.ExceptionHandler != nil {
 				task.taskService.ExceptionHandler(task.Context(), err)

looptask.go

@@ -107,7 +107,8 @@ func NewLoopTask(taskID string, isRun bool, dueTime int64, interval int64, handl
 func startLoopTask(task *LoopTask) {
 	handler := func() {
 		defer func() {
-			task.context.Header = nil
+			task.Context().Header = nil
+			task.Context().Error = nil
 			task.CounterInfo().RunCounter.Inc(1)
 			if err := recover(); err != nil {
 				task.CounterInfo().ErrorCounter.Inc(1)
@@ -130,6 +131,7 @@ func startLoopTask(task *LoopTask) {
 			err = task.handler(task.Context())
 		}
 		if err != nil {
+			task.Context().Error = err
 			task.CounterInfo().ErrorCounter.Inc(1)
 			if task.taskService != nil && task.taskService.ExceptionHandler != nil {
 				task.taskService.ExceptionHandler(task.Context(), err)

queuetask.go

@@ -102,6 +102,7 @@ func startQueueTask(task *QueueTask) {
 	handler := func() {
 		defer func() {
 			task.Context().Header = nil
+			task.Context().Error = nil
 			task.CounterInfo().RunCounter.Inc(1)
 			if err := recover(); err != nil {
 				task.CounterInfo().ErrorCounter.Inc(1)
@@ -125,6 +126,7 @@ func startQueueTask(task *QueueTask) {
 		}
 
 		if err != nil {
+			task.Context().Error = err
 			task.CounterInfo().ErrorCounter.Inc(1)
 			if task.taskService != nil && task.taskService.ExceptionHandler != nil {
 				task.taskService.ExceptionHandler(task.Context(), err)

taskinfo.go

@@ -45,6 +45,7 @@ type (
 		TaskData interface{} //用于当前Task全局设置的数据项
 		Message  interface{} //用于每次Task执行上下文消息传输
 		IsEnd    bool        //如果设置该属性为true，则停止当次任务的后续执行，一般用在OnBegin中
+		Error    error
 		Header   map[string]interface{}
 	}
 

version.MD

@@ -1,7 +1,8 @@
 ## devfeel/dottask
 
 #### Version 0.9.8
-* feature: TaskContext增加Header,类型为Map[string]interface{},用于在一次执行周期内传递自定义数据，每次执行完会清除
+* feature: TaskContext增加Header属性,类型为Map[string]interface{},用于在一次执行周期内传递自定义数据，每次执行完置空
+* feature: TaskContext增加Error属性,类型为error,用于在一次执行周期内传递执行结果的Error信息，每次执行完置空
 * 2020-03-28 16:00 at ShangHai
 
 #### Version 0.9.7