()
| 217 | } |
| 218 | |
| 219 | func (t *DBTask) Executed() time.Duration { |
| 220 | t.mu.Lock() |
| 221 | defer t.mu.Unlock() |
| 222 | |
| 223 | if t.Task != nil { |
| 224 | return t.Task.PublicState.ExecutedDuration |
| 225 | } |
| 226 | return 0 |
| 227 | } |
| 228 | |
| 229 | func (t *DBTask) Retried() int { |
| 230 | t.mu.Lock() |