CancelExecution 取消执行
(executionID string)
| 257 | |
| 258 | // CancelExecution 取消执行 |
| 259 | func (e *Engine) CancelExecution(executionID string) error { |
| 260 | e.executionsMu.RLock() |
| 261 | _, exists := e.executions[executionID] |
| 262 | e.executionsMu.RUnlock() |
| 263 | |
| 264 | if !exists { |
| 265 | return fmt.Errorf("execution not found: %s", executionID) |
| 266 | } |
| 267 | |
| 268 | e.cancelExecution(executionID) |
| 269 | return nil |
| 270 | } |
| 271 | |
| 272 | // PauseExecution 暂停执行 |
| 273 | func (e *Engine) PauseExecution(executionID string) error { |
no test coverage detected