@@ -239,6 +239,7 @@ namespace NKikimr::NKqp {
239239 std::vector<ui16> colData = {10 , 20 , 30 , 40 , 50 };
240240 clientMock->ExpectReadSplits ()
241241 .Filtering (NYql::NConnector::NApi::TReadSplitsRequest::FILTERING_OPTIONAL)
242+ .DataSourceInstance (dataSourceInstance)
242243 .Split ()
243244 .Description (" some binary description" )
244245 .Select ()
@@ -360,6 +361,7 @@ namespace NKikimr::NKqp {
360361 // step 3: ReadSplits
361362 clientMock->ExpectReadSplits ()
362363 .Filtering (NYql::NConnector::NApi::TReadSplitsRequest::FILTERING_OPTIONAL)
364+ .DataSourceInstance (dataSourceInstance)
363365 .Split ()
364366 .Description (" some binary description" )
365367 .Select ()
@@ -477,6 +479,7 @@ namespace NKikimr::NKqp {
477479 // step 3: ReadSplits
478480 clientMock->ExpectReadSplits ()
479481 .Filtering (NYql::NConnector::NApi::TReadSplitsRequest::FILTERING_OPTIONAL)
482+ .DataSourceInstance (dataSourceInstance)
480483 .Split ()
481484 .Description (" some binary description" )
482485 .Select ()
@@ -598,6 +601,7 @@ namespace NKikimr::NKqp {
598601
599602 f->ClientMock ->ExpectReadSplits ()
600603 .Filtering (NYql::NConnector::NApi::TReadSplitsRequest::FILTERING_OPTIONAL)
604+ .DataSourceInstance (f->DataSourceInstance )
601605 .Split ()
602606 .Description (" some binary description" )
603607 .Select (expectedSelect)
0 commit comments