()
| 1791 | } |
| 1792 | |
| 1793 | func (r *basePoolManager) runnerCleanup() (err error) { |
| 1794 | slog.DebugContext( |
| 1795 | r.ctx, "running runner cleanup") |
| 1796 | runners, err := r.GetGithubRunners() |
| 1797 | if err != nil { |
| 1798 | return fmt.Errorf("failed to fetch github runners: %w", err) |
| 1799 | } |
| 1800 | |
| 1801 | if err := r.reapTimedOutRunners(runners); err != nil { |
| 1802 | return fmt.Errorf("failed to reap timed out runners: %w", err) |
| 1803 | } |
| 1804 | |
| 1805 | if err := r.cleanupOrphanedRunners(runners); err != nil { |
| 1806 | return fmt.Errorf("failed to cleanup orphaned runners: %w", err) |
| 1807 | } |
| 1808 | |
| 1809 | return nil |
| 1810 | } |
| 1811 | |
| 1812 | func (r *basePoolManager) cleanupOrphanedRunners(runners []forgeRunner) error { |
| 1813 | if err := r.cleanupOrphanedProviderRunners(runners); err != nil { |
nothing calls this directly
no test coverage detected