(ctx context.Context, state *bootState)
| 504 | } |
| 505 | |
| 506 | func (d *Daemon) bootTaskRoles(ctx context.Context, state *bootState) error { |
| 507 | if state == nil || state.tasks == nil || state.tasks.store == nil || state.sessions == nil { |
| 508 | return nil |
| 509 | } |
| 510 | runtime, err := newTaskRoleRuntime(state.tasks.store, state.sessions, d.homePaths.HomeDir, state.logger, d.now) |
| 511 | if err != nil { |
| 512 | return err |
| 513 | } |
| 514 | if state.notifier != nil { |
| 515 | state.notifier.AddTaskRunEnqueuedObserver(runtime) |
| 516 | } |
| 517 | runtime.Recover(ctx) |
| 518 | state.tasks.roles.Store(runtime) |
| 519 | return nil |
| 520 | } |
| 521 | |
| 522 | func taskManagerOptions( |
| 523 | store taskStore, |
no test coverage detected