(ctx context.Context, reference *Reference)
| 3957 | } |
| 3958 | |
| 3959 | func (m *Service) applyEffectivePauseToReference(ctx context.Context, reference *Reference) error { |
| 3960 | if reference == nil { |
| 3961 | return nil |
| 3962 | } |
| 3963 | reference.EffectivePaused = reference.Paused |
| 3964 | if reference.Paused { |
| 3965 | reference.PausedByTaskID = reference.ID |
| 3966 | } |
| 3967 | reader, ok := m.store.(effectiveTaskPauseReader) |
| 3968 | if !ok { |
| 3969 | return nil |
| 3970 | } |
| 3971 | paused, pausedByTaskID, err := reader.IsTaskEffectivelyPaused(ctx, reference.ID) |
| 3972 | if err != nil { |
| 3973 | return err |
| 3974 | } |
| 3975 | reference.EffectivePaused = paused |
| 3976 | reference.PausedByTaskID = pausedByTaskID |
| 3977 | return nil |
| 3978 | } |
| 3979 | |
| 3980 | func activeRunSummary(runs []Run, maxAttempts int) *RunSummary { |
| 3981 | var current *Run |
no test coverage detected