diff options
author | hcpp <hcpp@ydb.tech> | 2023-07-13 13:32:53 +0300 |
---|---|---|
committer | hcpp <hcpp@ydb.tech> | 2023-07-13 13:32:53 +0300 |
commit | 76d431300e8fd0c43eca55f77c4dd8ae8d70fc38 (patch) | |
tree | a754ebc56c5ff14be1d37d1b2fb3888e80eea7b3 | |
parent | 29af8e948c107287829960447e0229406e7b48db (diff) | |
download | ydb-76d431300e8fd0c43eca55f77c4dd8ae8d70fc38.tar.gz |
compilation has been fixed
-rw-r--r-- | ydb/core/kqp/ut/service/kqp_query_service_ut.cpp | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/ydb/core/kqp/ut/service/kqp_query_service_ut.cpp b/ydb/core/kqp/ut/service/kqp_query_service_ut.cpp index 3fed3346bf..8e7df95f89 100644 --- a/ydb/core/kqp/ut/service/kqp_query_service_ut.cpp +++ b/ydb/core/kqp/ut/service/kqp_query_service_ut.cpp @@ -915,7 +915,7 @@ Y_UNIT_TEST_SUITE(KqpQueryService) { status = client.Cancel(scriptExecutionOperation.Id()).ExtractValueSync(); UNIT_ASSERT_C(status.GetStatus() == NYdb::EStatus::NOT_FOUND, status.GetIssues().ToString()); - TFetchScriptResultsResult results = db.FetchScriptResults(scriptExecutionOperation, 0).ExtractValueSync(); + TFetchScriptResultsResult results = db.FetchScriptResults(scriptExecutionOperation.Id(), 0).ExtractValueSync(); UNIT_ASSERT_C(results.GetStatus() == NYdb::EStatus::NOT_FOUND, results.GetIssues().ToString()); } @@ -933,7 +933,7 @@ Y_UNIT_TEST_SUITE(KqpQueryService) { UNIT_ASSERT_VALUES_EQUAL_C(scriptExecutionOperation.Status().GetStatus(), EStatus::SUCCESS, scriptExecutionOperation.Status().GetIssues().ToString()); WaitScriptExecutionOperation(scriptExecutionOperation.Id(), kikimr.GetDriver()); - TFetchScriptResultsResult results = db.FetchScriptResults(scriptExecutionOperation, 0).ExtractValueSync(); + TFetchScriptResultsResult results = db.FetchScriptResults(scriptExecutionOperation.Id(), 0).ExtractValueSync(); UNIT_ASSERT_C(results.IsSuccess(), results.GetIssues().ToString()); TResultSetParser resultSet(results.ExtractResultSet()); UNIT_ASSERT_C(resultSet.TryNextRow(), results.GetIssues().ToString()); @@ -941,7 +941,7 @@ Y_UNIT_TEST_SUITE(KqpQueryService) { while (results.GetStatus() != NYdb::EStatus::NOT_FOUND) { UNIT_ASSERT_C(results.IsSuccess(), results.GetIssues().ToString()); - results = db.FetchScriptResults(scriptExecutionOperation.Metadata().ExecutionId, 0).ExtractValueSync(); + results = db.FetchScriptResults(scriptExecutionOperation.Id(), 0).ExtractValueSync(); Sleep(TDuration::MilliSeconds(10)); } |