()
| 271 | } |
| 272 | |
| 273 | func (t *DBTask) CorrelationID() uuid.UUID { |
| 274 | t.mu.Lock() |
| 275 | defer t.mu.Unlock() |
| 276 | |
| 277 | if t.Task != nil { |
| 278 | return t.Task.CorrelationID |
| 279 | } |
| 280 | return uuid.Nil |
| 281 | } |
| 282 | |
| 283 | func (t *DBTask) ShouldPersist() bool { |
| 284 | return true |