datautils

type DataDecoderValidator interface {
	DecodeAndValidate(input, target interface{}) error
}

type DataDecoderValidatorOpt func(*DataDecoderValidatorOpts)

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

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

type JobRunLookupData struct {
	Input       map[string]interface{}            `json:"input"`
	TriggeredBy TriggeredBy                       `json:"triggered_by"`
	Steps       map[string]map[string]interface{} `json:"steps,omitempty"`
}

type StepRunData struct {
	Input       map[string]interface{}            `json:"input"`
	TriggeredBy TriggeredBy                       `json:"triggered_by"`
	Parents     map[string]map[string]interface{} `json:"parents"`

	// custom-set user data for the step
	UserData map[string]interface{} `json:"user_data"`

	// overrides set from the playground
	Overrides map[string]interface{} `json:"overrides"`

	// errors in upstream steps (only used in on-failure step)
	StepRunErrors map[string]string `json:"step_run_errors,omitempty"`
}

type TriggeredBy string