Fix linter errors

internal/infer/infer_test.go

@@ -38,7 +38,7 @@ var testData = []testEntry{
 		"foo",
 		nil,
 		schema.TypeIDString,
-		func(t schema.Type) error {
+		func(_ schema.Type) error {
 			return nil
 		},
 	},
@@ -93,7 +93,7 @@ var testData = []testEntry{
 			}),
 		),
 		schema.TypeIDString,
-		func(t schema.Type) error {
+		func(_ schema.Type) error {
 			return nil
 		},
 	},

workflow/executor.go

@@ -985,6 +985,9 @@ func (e *executor) prepareDependencies( //nolint:gocognit,gocyclo
 				return err
 			}
 			err = currentNode.ConnectDependency(oneofDagNode.ID(), dgraph.AndDependency)
+			if err != nil {
+				return err
+			}
 			// Mark the node ID on the OneOfExpression
 			s.Node = oneofDagNode.ID()
 			for optionID, optionData := range s.Options {

workflow/workflow.go

@@ -132,7 +132,7 @@ func (e *executableWorkflow) Execute(ctx context.Context, serializedInput any) (
 
 		var stageHandler step.StageChangeHandler = &stageChangeHandler{
 			onStageChange: func(
-				step step.RunningStep,
+				_ step.RunningStep,
 				previousStage *string,
 				previousStageOutputID *string,
 				previousStageOutput *any,
@@ -148,7 +148,7 @@ func (e *executableWorkflow) Execute(ctx context.Context, serializedInput any) (
 				l.onStageComplete(stepID, previousStage, previousStageOutputID, previousStageOutput, wg)
 			},
 			onStepComplete: func(
-				step step.RunningStep,
+				_ step.RunningStep,
 				previousStage string,
 				previousStageOutputID *string,
 				previousStageOutput *any,
@@ -161,7 +161,7 @@ func (e *executableWorkflow) Execute(ctx context.Context, serializedInput any) (
 				}
 				l.onStageComplete(stepID, &previousStage, previousStageOutputID, previousStageOutput, wg)
 			},
-			onStepStageFailure: func(step step.RunningStep, stage string, wg *sync.WaitGroup, err error) {
+			onStepStageFailure: func(_ step.RunningStep, stage string, _ *sync.WaitGroup, err error) {
 				if err == nil {
 					e.logger.Debugf("Step %q stage %q declared that it will not produce an output", stepID, stage)
 				} else {
@@ -698,11 +698,10 @@ func (l *loopState) resolveExpressions(inputData any, dataModel any) (any, error
 		dependencies := oneOfNode.ResolvedDependencies()
 		firstResolvedDependency := ""
 		for dependency, dependencyType := range dependencies {
-			switch dependencyType {
-			case dgraph.OrDependency:
+			if dependencyType == dgraph.OrDependency {
 				firstResolvedDependency = dependency
 				break
-			case dgraph.ObviatedDependency:
+			} else if dependencyType == dgraph.ObviatedDependency {
 				l.logger.Infof("Multiple OR cases triggered; skipping %q", dependency)
 			}
 		}

workflow/yaml.go

@@ -50,8 +50,13 @@ func (y yamlConverter) FromYAML(data []byte) (*Workflow, error) {
 	return workflow, nil
 }
 
+// YamlOneOfKey is the key to specify the oneof options within a !oneof section.
 const YamlOneOfKey = "one_of"
+
+// YamlDiscriminatorKey is the key to specify the discriminator inside a !oneof section.
 const YamlDiscriminatorKey = "discriminator"
+
+// YamlOneOfTag is the yaml tag that allows the section to be interpreted as a OneOf.
 const YamlOneOfTag = "!oneof"
 
 func buildOneOfExpressions(data yaml.Node, path []string) (any, error) {
@@ -76,7 +81,7 @@ func buildOneOfExpressions(data yaml.Node, path []string) (any, error) {
 	for _, optionNodeKey := range oneOfOptionsNode.MapKeys() {
 		optionNode, _ := oneOfOptionsNode.MapKey(optionNodeKey)
 		var err error
-		options[optionNodeKey], err = yamlBuildExpressions(optionNode, append(path))
+		options[optionNodeKey], err = yamlBuildExpressions(optionNode, append(path, optionNodeKey))
 		if err != nil {
 			return nil, err
 		}