(err error, retryCount int)
| 351 | } |
| 352 | |
| 353 | func (o *ExecuteOptions) LogRetryInfo(err error, retryCount int) { |
| 354 | if o == nil || o.CreateTaskRunLog == nil { |
| 355 | return |
| 356 | } |
| 357 | err = o.CreateTaskRunLog(time.Now(), &storepb.TaskRunLog{ |
| 358 | Type: storepb.TaskRunLog_RETRY_INFO, |
| 359 | RetryInfo: &storepb.TaskRunLog_RetryInfo{ |
| 360 | Error: err.Error(), |
| 361 | RetryCount: int32(retryCount), |
| 362 | MaximumRetries: int32(o.MaximumRetries), |
| 363 | }, |
| 364 | }) |
| 365 | if err != nil { |
| 366 | slog.Warn("failed to log retry info", log.BBError(err)) |
| 367 | } |
| 368 | } |
| 369 | |
| 370 | func (o *ExecuteOptions) LogTransactionControl(t storepb.TaskRunLog_TransactionControl_Type, rerr string) { |
| 371 | if o == nil || o.CreateTaskRunLog == nil { |
no test coverage detected