( ctx context.Context, state *bootState, manager *taskpkg.Service, store taskStore, )
| 407 | } |
| 408 | |
| 409 | func recoverBootTaskRuns( |
| 410 | ctx context.Context, |
| 411 | state *bootState, |
| 412 | manager *taskpkg.Service, |
| 413 | store taskStore, |
| 414 | ) error { |
| 415 | actor, err := taskpkg.DeriveDaemonActorContext("boot-recovery", "daemon.boot") |
| 416 | if err != nil { |
| 417 | return fmt.Errorf("daemon: derive task boot recovery actor: %w", err) |
| 418 | } |
| 419 | stats, err := recoverTaskRunsOnBoot(ctx, manager, store, state.sessions, actor) |
| 420 | if err != nil { |
| 421 | return err |
| 422 | } |
| 423 | if stats.requeued+stats.markedRunning+stats.failed > 0 { |
| 424 | state.logger.Info( |
| 425 | "daemon: task boot recovery complete", |
| 426 | "requeued_runs", stats.requeued, |
| 427 | "resumed_running_runs", stats.markedRunning, |
| 428 | "failed_runs", stats.failed, |
| 429 | ) |
| 430 | } |
| 431 | return nil |
| 432 | } |
| 433 | |
| 434 | func bootHarnessReentryBridge(ctx context.Context, state *bootState) (*harnessReentryBridge, error) { |
| 435 | reentrySessions, ok := state.sessions.(harnessReentrySessionManager) |
no test coverage detected