Function TestFunctionCall_Execute

go/engine/node/functioncall_test.go:126–261

(t *testing.T)

}

func TestFunctionCall_Execute(t *testing.T) {
	t.Run("evaluates input bindings, runs fn, applies output bindings", func(t *testing.T) {
		s, err := engine.NewMainScope([]workflowapi.Variable{
			{Uid: "x", DataType: workflowapi.Int, InitialValue: float64(11)},
			{Uid: "y", DataType: workflowapi.Int}, // assign target
		})
		require.NoError(t, err)

		fn := passthroughFn()
		fc, err := NewFunctionCall("fc", fn,
			map[string]workflowapi.Expression{
				"a": {
					Expression: "${}",
					DataType:   workflowapi.Int,
					References: []workflowapi.Reference{{SrcId: engine.SrcDeclared, VarId: "x"}},
				},
			},
			map[string]workflowapi.OutputBinding{
				"ret": {
					Active: true,
					Mode:   workflowapi.OutputBindingModeAssign,
					Target: &workflowapi.Reference{SrcId: engine.SrcDeclared, VarId: "y"},
				},
			},
			"",
		)
		require.NoError(t, err)

		next, err := fc.Execute(context.Background(), s)
		require.NoError(t, err)
		assert.Equal(t, engine.StateIdle, next)

		v, err := s.Resolve(workflowapi.Reference{SrcId: engine.SrcDeclared, VarId: "y"})
		require.NoError(t, err)
		assert.Equal(t, expr.IntVal(11), v)
	})

	t.Run("input expression error is wrapped with node and arg name", func(t *testing.T) {
		s, err := engine.NewMainScope(nil)
		require.NoError(t, err)

		fn := passthroughFn()
		fc, err := NewFunctionCall("fc-bad", fn,
			map[string]workflowapi.Expression{
				"a": {
					Expression: "${}",
					DataType:   workflowapi.Int,
					References: []workflowapi.Reference{{SrcId: "missing", VarId: "x"}},
				},
			},
			map[string]workflowapi.OutputBinding{
				"ret": {Active: true, Mode: workflowapi.OutputBindingModeEmit},
			},
			"",
		)
		require.NoError(t, err)

		_, err = fc.Execute(context.Background(), s)