spawner

type JobSpawner interface {
	// SpawnJob creates a K8s Job for the task and returns the job name.
	// Returns the job name even when the job already exists (idempotent).
	SpawnJob(ctx context.Context, task lib.Task, config pkg.AgentConfiguration) (string, error)
	// IsJobActive returns true if an active (not completed/failed) K8s Job exists
	// for the given task identifier. Uses the agent.benjamin-borbe.de/task-id
	// label set by SpawnJob.
	IsJobActive(ctx context.Context, taskIdentifier lib.TaskIdentifier) (bool, error)
	// CountActiveJobs returns the number of non-terminal K8s Jobs currently
	// running for the given assignee. Uses the agent.benjamin-borbe.de/assignee
	// label set by SpawnJob. Jobs spawned before that label existed are not
	// counted, so the cap under-counts during the rollout and never over-counts.
	CountActiveJobs(ctx context.Context, assignee string) (int, error)
}