Function TestFlowStepNamesMustBeUnique

flow/steps_test.go:383–399

(t *testing.T)

}

func TestFlowStepNamesMustBeUnique(t *testing.T) {
	step := Step{Name: "work", Run: func(_ context.Context, in State) (State, error) {
		return in, nil
	}}
	f := New("duplicate-steps",
		WithCheckpoint(StoreCheckpoint(store.NewMemoryStore(), "duplicate-steps")),
		Steps(step, step),
	)

	err := f.Execute(context.Background(), "")
	if err == nil {
		t.Fatal("expected duplicate step names to fail validation")
	}
	if got, want := err.Error(), `flow: duplicate step name "work"`; got != want {
		t.Fatalf("error = %q, want %q", got, want)
	}
}

func TestFlowStepNamesMustBeNonEmpty(t *testing.T) {
	f := New("empty-step-name",