diff --git a/tests/integration/basic_example_query_test.go b/tests/integration/basic_example_query_test.go index a447d8510..b6067dbac 100644 --- a/tests/integration/basic_example_query_test.go +++ b/tests/integration/basic_example_query_test.go @@ -144,7 +144,9 @@ func TestBasicExampleQuery(sourceTest *testing.T) { //nolint:gocyclo PRIMARY KEY(series_id) )`, ) - require.NoError(t, err) + if ctx.Err() == nil { + require.NoError(t, err) + } }) t.Run("seasons", func(t *testing.T) { err := db.Query().Exec(ctx, ` @@ -162,7 +164,9 @@ func TestBasicExampleQuery(sourceTest *testing.T) { //nolint:gocyclo PRIMARY KEY(series_id,season_id) )`, ) - require.NoError(t, err) + if ctx.Err() == nil { + require.NoError(t, err) + } }) t.Run("episodes", func(t *testing.T) { err := db.Query().Exec(ctx, ` @@ -181,7 +185,9 @@ func TestBasicExampleQuery(sourceTest *testing.T) { //nolint:gocyclo PRIMARY KEY(series_id,season_id,episode_id) )`, ) - require.NoError(t, err) + if ctx.Err() == nil { + require.NoError(t, err) + } }) }) }) @@ -246,7 +252,9 @@ func TestBasicExampleQuery(sourceTest *testing.T) { //nolint:gocyclo ), query.WithIdempotent(), ) - require.NoError(t, err) + if ctx.Err() == nil { + require.NoError(t, err) + } }) }) @@ -310,7 +318,9 @@ func TestBasicExampleQuery(sourceTest *testing.T) { //nolint:gocyclo }, query.WithIdempotent(), ) - require.NoError(t, err) + if ctx.Err() == nil { + require.NoError(t, err) + } }) }) @@ -338,10 +348,12 @@ func TestBasicExampleQuery(sourceTest *testing.T) { //nolint:gocyclo Build(), ), ) - require.NoError(t, err) - var views uint64 - require.NoError(t, row.Scan(&views)) - require.EqualValues(t, 1, views) + if ctx.Err() == nil { + require.NoError(t, err) + var views uint64 + require.NoError(t, row.Scan(&views)) + require.EqualValues(t, 1, views) + } }) }) @@ -376,17 +388,19 @@ func TestBasicExampleQuery(sourceTest *testing.T) { //nolint:gocyclo query.WithParameters(ydb.ParamsBuilder().Param("$seriesID").Uint64(1).Build()), query.WithTxControl(query.SnapshotReadOnlyTxControl()), ) - require.NoError(t, err) - var ( - id *uint64 - title *string - date *time.Time - ) - require.NoError(t, row.Scan(&id, &title, &date)) - t.Logf( - " > %d %s %s\n", - *id, *title, *date, - ) + if ctx.Err() == nil { + require.NoError(t, err) + var ( + id *uint64 + title *string + date *time.Time + ) + require.NoError(t, row.Scan(&id, &title, &date)) + t.Logf( + " > %d %s %s\n", + *id, *title, *date, + ) + } }) t.Run("ScanQuery", func(t *testing.T) { @@ -438,6 +452,8 @@ func TestBasicExampleQuery(sourceTest *testing.T) { //nolint:gocyclo return nil }, query.WithIdempotent()) - require.NoError(t, err) + if ctx.Err() == nil { + require.NoError(t, err) + } }) }