diff --git a/abstract.go b/abstract.go index e2d419c..e2ddd58 100644 --- a/abstract.go +++ b/abstract.go @@ -21,7 +21,7 @@ type ITask interface { Description() string // GetRunID 获取任务ID GetRunID() string - // Callback 任务执行的回调 + // Callback 任务执行成功的回调 Callback(result *Result) error // Execute 执行任务 Execute(ctx context.Context, cfg *Config) (map[string]interface{}, error) diff --git a/define.go b/define.go index 873c790..93fe2f5 100644 --- a/define.go +++ b/define.go @@ -37,6 +37,7 @@ type Result struct { TaskRunID string // 任务运行ID TaskDescription string // 任务描述 TaskConfig *Config // 任务配置 + Async bool // 是否运行 Data map[string]interface{} // 任务结果数据 Err error // 异常信息, err == nil , 代表执行成功 } diff --git a/task.go b/task.go index f9b0e28..8b3e164 100644 --- a/task.go +++ b/task.go @@ -93,6 +93,7 @@ func (d *dispatch) Run(ctx context.Context, cfg *Config) *Result { TaskConfig: cfg, Data: nil, Err: nil, + Async: cfg.Async, } defer func() { result.FinishTime = time.Now().UnixNano()