fix IsSuccess

kardymonds · kardymonds · commit bacb1afc8edc · 2025-08-08T12:02:53.000Z
diff --git a/ydb/core/fq/libs/control_plane_storage/ydb_control_plane_storage.cpp b/ydb/core/fq/libs/control_plane_storage/ydb_control_plane_storage.cpp
@@ -527,7 +527,7 @@ NThreading::TFuture<void> TYdbControlPlaneStorageActor::PickTask(
         taskParams.PrepareParams, requestCounters, debugInfo, validators, transactionMode, taskParams.RetryOnTli)
             .Apply([=, responseTasks=responseTasks, queryId = taskParams.QueryId](const auto& future) {
                 const auto status = future.GetValue();
-                if (responseTasks && status.GetStatus() == EStatus::GENERIC_ERROR) {
+                if (responseTasks && !status.IsSuccess()) {
                     responseTasks->SafeEraseTaskBlocking(queryId);
                 }
             });

Original file line number	Diff line number	Diff line change
`@@ -527,7 +527,7 @@ NThreading::TFuture<void> TYdbControlPlaneStorageActor::PickTask(`
`527`	`527`	`taskParams.PrepareParams, requestCounters, debugInfo, validators, transactionMode, taskParams.RetryOnTli)`
`528`	`528`	`.Apply([=, responseTasks=responseTasks, queryId = taskParams.QueryId](const auto& future) {`
`529`	`529`	`const auto status = future.GetValue();`
`530`		`- if (responseTasks && status.GetStatus() == EStatus::GENERIC_ERROR) {`
	`530`	`+ if (responseTasks && !status.IsSuccess()) {`
`531`	`531`	`responseTasks->SafeEraseTaskBlocking(queryId);`
`532`	`532`	`}`
`533`	`533`	`});`