(derr string)
| 271 | } |
| 272 | |
| 273 | func (o *ExecuteOptions) LogSchemaDumpEnd(derr string) { |
| 274 | if o == nil || o.CreateTaskRunLog == nil { |
| 275 | return |
| 276 | } |
| 277 | err := o.CreateTaskRunLog(time.Now(), &storepb.TaskRunLog{ |
| 278 | Type: storepb.TaskRunLog_SCHEMA_DUMP_END, |
| 279 | SchemaDumpEnd: &storepb.TaskRunLog_SchemaDumpEnd{ |
| 280 | Error: derr, |
| 281 | }, |
| 282 | }) |
| 283 | if err != nil { |
| 284 | slog.Warn("failed to log schema dump end", log.BBError(err)) |
| 285 | } |
| 286 | } |
| 287 | |
| 288 | // LogCommandExecute logs the execution of a command. |
| 289 | func (o *ExecuteOptions) LogCommandExecute(commandRange *storepb.Range, commandText string) { |
nothing calls this directly
no test coverage detected