diff options
| author | Nikita Vasilev <[email protected]> | 2025-10-15 18:10:22 +0300 |
|---|---|---|
| committer | GitHub <[email protected]> | 2025-10-15 18:10:22 +0300 |
| commit | 169f7b7cad2d1d5017cb5cbffaf1a425f3ed3205 (patch) | |
| tree | 1e0d07f3ccb7a9c7a5369ce4537eea9aa51b5a74 | |
| parent | 9d5694d347dedaf5242ad5f18cab1e6a26508c66 (diff) | |
Fix muted tests (#26844)
| -rw-r--r-- | .github/config/muted_ya.txt | 1 | ||||
| -rw-r--r-- | ydb/core/kqp/opt/kqp_query_plan.cpp | 2 | ||||
| -rw-r--r-- | ydb/core/kqp/ut/service/kqp_qs_queries_ut.cpp | 1 |
3 files changed, 3 insertions, 1 deletions
diff --git a/.github/config/muted_ya.txt b/.github/config/muted_ya.txt index 6986a55143e..56533f47e12 100644 --- a/.github/config/muted_ya.txt +++ b/.github/config/muted_ya.txt @@ -19,7 +19,6 @@ ydb/core/kqp/ut/opt KqpKv.ReadRows_TimeoutCancelsReads ydb/core/kqp/ut/query KqpAnalyze.AnalyzeTable+ColumnStore ydb/core/kqp/ut/scheme KqpAcl.AlterDatabasePrivilegesRequiredToChangeSchemeLimits-AsClusterAdmin ydb/core/kqp/ut/scheme KqpOlapScheme.AddPgColumnWithStore -ydb/core/kqp/ut/service KqpQueryService.LargeUpsert-UseSink ydb/core/kqp/ut/service KqpQueryServiceScripts.ExecuteScriptWithCancelAfterAndTimeout ydb/core/persqueue/ut TPQTest.TestPartitionWriteQuota ydb/core/persqueue/ut/slow SlowTopicAutopartitioning.CDC_Write diff --git a/ydb/core/kqp/opt/kqp_query_plan.cpp b/ydb/core/kqp/opt/kqp_query_plan.cpp index c6881209d8c..311ce49e0f3 100644 --- a/ydb/core/kqp/opt/kqp_query_plan.cpp +++ b/ydb/core/kqp/opt/kqp_query_plan.cpp @@ -3179,6 +3179,7 @@ TString AddExecStatsToTxPlan(const TString& txPlanJson, const NYql::NDqProto::TD for (auto input : (*stat)->GetInput()) { auto& inputInfo = inputStats.AppendValue(NJson::JSON_MAP); auto stageGuid = stageIdToGuid.at(input.first); + AFL_ENSURE(guidToPlaneId.contains(stageGuid)); auto planNodeId = guidToPlaneId.at(stageGuid); inputInfo["Name"] = ToString(planNodeId); if (input.second.HasPush()) { @@ -3197,6 +3198,7 @@ TString AddExecStatsToTxPlan(const TString& txPlanJson, const NYql::NDqProto::TD outputInfo["Name"] = "RESULT"; } else { auto stageGuid = stageIdToGuid.at(output.first); + AFL_ENSURE(guidToPlaneId.contains(stageGuid)); auto planNodeId = guidToPlaneId.at(stageGuid); outputInfo["Name"] = ToString(planNodeId); } diff --git a/ydb/core/kqp/ut/service/kqp_qs_queries_ut.cpp b/ydb/core/kqp/ut/service/kqp_qs_queries_ut.cpp index d194baea04c..f1d89149889 100644 --- a/ydb/core/kqp/ut/service/kqp_qs_queries_ut.cpp +++ b/ydb/core/kqp/ut/service/kqp_qs_queries_ut.cpp @@ -6320,6 +6320,7 @@ Y_UNIT_TEST_SUITE(KqpQueryService) { auto result = session.ExecuteQuery(query, TTxControl::Tx(tx), params.Build()).GetValueSync(); UNIT_ASSERT_C(result.IsSuccess(), result.GetIssues().ToString()); + Sleep(TDuration::MilliSeconds(500)); } auto commitResult = tx.Commit().GetValueSync(); |