Skip to content

Commit f780206

Browse files
committed
fix: ensure results and errors channels are closed after workflow execution in tests
1 parent faeacb4 commit f780206

File tree

1 file changed

+4
-3
lines changed

1 file changed

+4
-3
lines changed

dbos/workflows_test.go

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -639,15 +639,16 @@ func TestGoRunningStepsInsideGoRoutines(t *testing.T) {
639639
}
640640
return "", nil
641641
}
642-
close(results)
643-
close(errors)
644642

645643
RegisterWorkflow(dbosCtx, goWorkflow)
646644
handle, err := RunWorkflow(dbosCtx, goWorkflow, "test-input")
647645
require.NoError(t, err, "failed to run go workflow")
648646
_, err = handle.GetResult()
649-
require.NoError(t, err, "failed to get result from go workflow")
647+
648+
close(results)
649+
close(errors)
650650

651+
require.NoError(t, err, "failed to get result from go workflow")
651652
assert.Equal(t, numSteps, len(results), "expected %d results, got %d", numSteps, len(results))
652653
assert.Equal(t, 0, len(errors), "expected no errors, got %d", len(errors))
653654
})

0 commit comments

Comments
 (0)