(rerr string)
| 336 | } |
| 337 | |
| 338 | func (o *ExecuteOptions) LogGhostMigrationEnd(rerr string) { |
| 339 | if o == nil || o.CreateTaskRunLog == nil { |
| 340 | return |
| 341 | } |
| 342 | err := o.CreateTaskRunLog(time.Now(), &storepb.TaskRunLog{ |
| 343 | Type: storepb.TaskRunLog_GHOST_MIGRATION_END, |
| 344 | GhostMigrationEnd: &storepb.TaskRunLog_GhostMigrationEnd{ |
| 345 | Error: rerr, |
| 346 | }, |
| 347 | }) |
| 348 | if err != nil { |
| 349 | slog.Warn("failed to log gh-ost migration end", log.BBError(err)) |
| 350 | } |
| 351 | } |
| 352 | |
| 353 | func (o *ExecuteOptions) LogRetryInfo(err error, retryCount int) { |
| 354 | if o == nil || o.CreateTaskRunLog == nil { |
no test coverage detected