worker

type Jobs interface {
	ProcessNext(
		ctx context.Context,
		process func(ctx context.Context, job models.Job, execution *models.ExecutionContext) ([]models.Job, error),
	) (bool, error)
}

type Worker struct {
	// contains filtered or unexported fields
}

type Workflows interface {
	GetByID(ctx context.Context, id string) (*models.Workflow, error)
}