()
| 237 | } |
| 238 | |
| 239 | func (t *DBTask) Error() error { |
| 240 | t.mu.Lock() |
| 241 | defer t.mu.Unlock() |
| 242 | |
| 243 | if t.Task != nil && t.Task.PublicState.Error != "" { |
| 244 | return errors.New(t.Task.PublicState.Error) |
| 245 | } |
| 246 | |
| 247 | return nil |
| 248 | } |
| 249 | |
| 250 | func (t *DBTask) ErrorHistory() []error { |
| 251 | t.mu.Lock() |