Skip to content

Commit b25be56

Browse files
committed
microsoft_sql_server_cdc: fix stream lifecycle in schema metadata test
1 parent 48c3965 commit b25be56

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

internal/impl/mssqlserver/integration_test.go

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -11,6 +11,7 @@ package mssqlserver_test
1111
import (
1212
"context"
1313
"database/sql"
14+
"errors"
1415
"fmt"
1516
"sync"
1617
"testing"
@@ -759,7 +760,9 @@ microsoft_sql_server_cdc:
759760
license.InjectTestService(stream.Resources())
760761

761762
go func() {
762-
require.NoError(t, stream.Run(t.Context()))
763+
if err := stream.Run(t.Context()); err != nil && !errors.Is(err, context.Canceled) {
764+
t.Error(err)
765+
}
763766
}()
764767

765768
// Wait for the snapshot row to arrive.

0 commit comments

Comments
 (0)