From 098713ba775552289a542428b38b64e82ce25eed Mon Sep 17 00:00:00 2001 From: Oleg Doronin Date: Fri, 26 Jan 2024 16:37:47 +0300 Subject: [PATCH] Checking "not found" status has been added to Stopper (#1263) --- ydb/core/fq/libs/compute/ydb/stopper_actor.cpp | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/ydb/core/fq/libs/compute/ydb/stopper_actor.cpp b/ydb/core/fq/libs/compute/ydb/stopper_actor.cpp index 78fd8a8b0efa..de66c3c1c167 100644 --- a/ydb/core/fq/libs/compute/ydb/stopper_actor.cpp +++ b/ydb/core/fq/libs/compute/ydb/stopper_actor.cpp @@ -81,13 +81,13 @@ class TStopperActor : public TBaseComputeActor { void Handle(const TEvYdbCompute::TEvCancelOperationResponse::TPtr& ev) { const auto& response = *ev.Get()->Get(); - if (response.Status != NYdb::EStatus::SUCCESS) { + if (response.Status != NYdb::EStatus::SUCCESS && response.Status != NYdb::EStatus::NOT_FOUND && response.Status != NYdb::EStatus::PRECONDITION_FAILED) { LOG_E("Can't cancel operation: " << ev->Get()->Issues.ToOneLineString()); - Send(Parent, new TEvYdbCompute::TEvStopperResponse(ev->Get()->Issues, ev->Get()->Status)); + Send(Parent, new TEvYdbCompute::TEvStopperResponse(response.Issues, response.Status)); FailedAndPassAway(); return; } - LOG_I("Operation successfully canceled"); + LOG_I("Operation successfully canceled: " << response.Status); Send(Parent, new TEvYdbCompute::TEvStopperResponse({}, NYdb::EStatus::SUCCESS)); CompleteAndPassAway(); }