Skip to content

Commit fcf5153

Browse files
author
willzhen
committed
Fixed panic
1 parent 24528fc commit fcf5153

File tree

1 file changed

+6
-2
lines changed

1 file changed

+6
-2
lines changed

actuator/function_actuator.go

+6-2
Original file line numberDiff line numberDiff line change
@@ -95,7 +95,9 @@ func (fc *fucntionActuator) Start(ctx context.Context, ftask *framework.Task) (
9595
// 任务可能因为超时被删除,或者手动暂停、不处理
9696
return
9797
}
98-
(st.([]interface{})[1].(context.CancelFunc))() // 任务执行完,也要执行对应的 cancel 函数
98+
if st.([]interface{})[1] != nil {
99+
(st.([]interface{})[1].(context.CancelFunc))() // 任务执行完,也要执行对应的 cancel 函数
100+
}
99101
var newStatus framework.AsyncTaskStatus
100102
if err != nil {
101103
newStatus = framework.AsyncTaskStatus{
@@ -140,7 +142,9 @@ func (fc *fucntionActuator) Stop(ctx context.Context, ftask *framework.Task) err
140142
return nil
141143
}
142144
fc.clear(ftask.TaskId)
143-
(st.([]interface{})[1].(context.CancelFunc))() // cancel 函数 ctx
145+
if st.([]interface{})[1] != nil {
146+
(st.([]interface{})[1].(context.CancelFunc))() // cancel 函数 ctx
147+
}
144148
return nil
145149
}
146150

0 commit comments

Comments
 (0)