summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorhor911 <[email protected]>2022-04-01 12:22:06 +0300
committerhor911 <[email protected]>2022-04-01 12:22:06 +0300
commit62185c186dfcebaecc120a5e5d7f307a2e305218 (patch)
tree8f27b82a4ab2d5c6554ae31c43cb674a4def2af1
parente84a22027f7a0a962827c8d6be4968a810b042db (diff)
Fix CF
ref:29d7ff1c588c276168832b4dbea1f54d8f680e14
-rw-r--r--ydb/library/yql/providers/external_function/cloud_function/actors/cloud_function_transform.cpp10
1 files changed, 5 insertions, 5 deletions
diff --git a/ydb/library/yql/providers/external_function/cloud_function/actors/cloud_function_transform.cpp b/ydb/library/yql/providers/external_function/cloud_function/actors/cloud_function_transform.cpp
index 2c008cf0576..c3a1183c225 100644
--- a/ydb/library/yql/providers/external_function/cloud_function/actors/cloud_function_transform.cpp
+++ b/ydb/library/yql/providers/external_function/cloud_function/actors/cloud_function_transform.cpp
@@ -99,9 +99,9 @@ STATEFN(TCloudFunctionTransformActor::DeadState) {
void TCloudFunctionTransformActor::Handle(TEvDq::TEvAbortExecution::TPtr& ev) {
auto& msg = ev->Get()->Record;
TIssues issues = ev->Get()->GetIssues();
- if (msg.GetStatusCode() == Ydb::StatusIds::INTERNAL_ERROR) {
+ if (msg.GetStatusCode() == NYql::NDqProto::StatusIds::INTERNAL_ERROR) {
InternalError(issues);
- } else if (msg.GetStatusCode() == Ydb::StatusIds::ABORTED) {
+ } else if (msg.GetStatusCode() == NYql::NDqProto::StatusIds::ABORTED) {
Aborted(issues);
} else {
RuntimeError(issues);
@@ -265,7 +265,7 @@ void TCloudFunctionTransformActor::RuntimeError(const TString& message, const TI
void TCloudFunctionTransformActor::RuntimeError(const TIssues& issues) {
TransformInProgress = false;
- auto ev = MakeHolder<TEvDq::TEvAbortExecution>(Ydb::StatusIds::UNAVAILABLE, issues);
+ auto ev = MakeHolder<TEvDq::TEvAbortExecution>(NYql::NDqProto::StatusIds::UNAVAILABLE, issues);
Send(Owner, ev.Release());
Become(&TCloudFunctionTransformActor::DeadState);
@@ -278,7 +278,7 @@ void TCloudFunctionTransformActor::InternalError(const TString& message, const T
void TCloudFunctionTransformActor::InternalError(const TIssues& issues) {
TransformInProgress = false;
- auto ev = MakeHolder<TEvDq::TEvAbortExecution>(Ydb::StatusIds::INTERNAL_ERROR, issues);
+ auto ev = MakeHolder<TEvDq::TEvAbortExecution>(NYql::NDqProto::StatusIds::INTERNAL_ERROR, issues);
Send(Owner, ev.Release());
Become(&TCloudFunctionTransformActor::DeadState);
@@ -291,7 +291,7 @@ void TCloudFunctionTransformActor::Aborted(const TString& message, const TIssues
void TCloudFunctionTransformActor::Aborted(const TIssues& issues) {
TransformInProgress = false;
- auto ev = MakeHolder<TEvDq::TEvAbortExecution>(Ydb::StatusIds::ABORTED, issues);
+ auto ev = MakeHolder<TEvDq::TEvAbortExecution>(NYql::NDqProto::StatusIds::ABORTED, issues);
Send(Owner, ev.Release());
Become(&TCloudFunctionTransformActor::DeadState);