Skip to content

Commit c8a0ca7

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

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
@@ -925,15 +925,16 @@ func TestGoRunningStepsInsideGoRoutines(t *testing.T) {
925925
}
926926
return "", nil
927927
}
928-
close(results)
929-
close(errors)
930928

931929
RegisterWorkflow(dbosCtx, goWorkflow)
932930
handle, err := RunWorkflow(dbosCtx, goWorkflow, "test-input")
933931
require.NoError(t, err, "failed to run go workflow")
934932
_, err = handle.GetResult()
935-
require.NoError(t, err, "failed to get result from go workflow")
933+
934+
close(results)
935+
close(errors)
936936

937+
require.NoError(t, err, "failed to get result from go workflow")
937938
assert.Equal(t, numSteps, len(results), "expected %d results, got %d", numSteps, len(results))
938939
assert.Equal(t, 0, len(errors), "expected no errors, got %d", len(errors))
939940
})

0 commit comments

Comments
 (0)