Skip to content

Commit

Permalink
Checking "not found" status has been added to Stopper (#1263)
Browse files Browse the repository at this point in the history
  • Loading branch information
dorooleg authored Jan 26, 2024
1 parent f85a414 commit 098713b
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions ydb/core/fq/libs/compute/ydb/stopper_actor.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -81,13 +81,13 @@ class TStopperActor : public TBaseComputeActor<TStopperActor> {

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();
}
Expand Down

0 comments on commit 098713b

Please sign in to comment.