runner

type Repo interface {
	Set(jobID string, runner Runner)
	Get(jobID string) Runner
	Remove(jobID string)
	Items() map[string]Runner
	Count() int
}

type Return struct {
	AtomReturn atom.Return // Final atom.Return Determines if/how chain continues running.
	Tries      uint        // Number of tries this run, not including any previous tries
}

type Runner interface {
	// Run runs the job, blocking until it has completed or when Stop is called.
	// If the job fails, Run will retry it as many times as the job is configured
	// to be retried. When the job successfully completes, or reaches the maximum number
	// of retry attempts, Run returns the final state of the job.
	Run(ctx context.Context) Return

	// Stop stops the job if it's running. The job is responsible for stopping
	// quickly because Stop blocks while waiting for the job to stop.
	Stop(ctx context.Context) error
}