redrive

type RedriveSweep ¶

type RedriveSweep interface {
	// Run blocks until ctx is cancelled, sweeping once per interval.
	Run(ctx context.Context) error
	// SweepOnce performs a single sweep pass. Exposed for unit tests so they do
	// not have to manage tickers. Returns an error only on git/pull failures;
	// per-task errors are logged.
	SweepOnce(ctx context.Context) error
}

RedriveSweep is a background loop that force re-publishes TaskUpdated events for eligible tasks that have never spawned a Job. The change-detecting scanner only emits an event when a task file's content hash changes; a task that sits unchanged since creation (e.g. a stub a collector wrote and then went quiet on) never produces a new event, so the executor — purely event-driven — never re-evaluates it. This sweep is the re-drive path: a task matching the executor's spawn filter but with no current_job (never spawned) gets its TaskUpdated re-emitted on a schedule, and the executor's own guards (active job, trigger cap, grace window) decide whether a spawn actually happens.

func NewRedriveSweep(
	gitClient gitrestclient.GitClient,
	publisher publisher.TaskPublisher,
	taskDir string,
	branch base.Branch,
	interval time.Duration,
	currentDateTime libtime.CurrentDateTimeGetter,
	m metrics.Metrics,
) RedriveSweep