From bf7502788949c59657dfa1994f55dbabdd776224 Mon Sep 17 00:00:00 2001 From: Kevin Wan Date: Wed, 30 Jul 2025 19:45:35 +0800 Subject: [PATCH] chore: add more tests (#5038) --- core/mr/mapreduce_test.go | 30 ++++++++++++++++++++++++++++++ 1 file changed, 30 insertions(+) diff --git a/core/mr/mapreduce_test.go b/core/mr/mapreduce_test.go index 6aa924f57..c0cc34cec 100644 --- a/core/mr/mapreduce_test.go +++ b/core/mr/mapreduce_test.go @@ -39,6 +39,36 @@ func TestFinish(t *testing.T) { assert.Nil(t, err) } +func TestFinishWithPartialErrors(t *testing.T) { + defer goleak.VerifyNone(t) + + errDummy := errors.New("dummy") + + t.Run("one error", func(t *testing.T) { + err := Finish(func() error { + return errDummy + }, func() error { + return nil + }, func() error { + return nil + }) + + assert.Equal(t, errDummy, err) + }) + + t.Run("two errors", func(t *testing.T) { + err := Finish(func() error { + return errDummy + }, func() error { + return errDummy + }, func() error { + return nil + }) + + assert.Equal(t, errDummy, err) + }) +} + func TestFinishNone(t *testing.T) { defer goleak.VerifyNone(t)