mirror/dolt
1
0
Fork 0
mirror of https://github.com/dolthub/dolt.git synced 2026-04-23 05:13:00 -05:00
Code Issues Packages Projects Releases 157 Wiki Activity

go/libraries/utils/pipeline: Fix unit test for new semantics.

Browse Source
This commit is contained in:
Aaron Son
2022-05-18 14:07:14 -07:00
parent a8f5e44786
commit ec7af0c507
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
go/libraries/utils/pipeline/pipeline_test.go
+2 -2
View File
@@ -133,7 +133,7 @@ func TestParallelProcessingPipeline(t *testing.T) {
transform := func(ctx context.Context, in []ItemWithProps) ([]ItemWithProps, error) {
if in == nil {
return nil, io.EOF
return nil, nil
}
routineIdex, ok := GetLocalStorage(ctx).Get(localStoreRoutineIndexID)
@@ -295,7 +295,7 @@ func TestMassParallelism(t *testing.T) {
transform := func(_ context.Context, in []ItemWithProps) ([]ItemWithProps, error) {
if in == nil {
return nil, io.EOF
return nil, nil
}
out := make([]ItemWithProps, len(in))