diff options
| author | hor911 <[email protected]> | 2022-04-01 12:22:06 +0300 |
|---|---|---|
| committer | hor911 <[email protected]> | 2022-04-01 12:22:06 +0300 |
| commit | 62185c186dfcebaecc120a5e5d7f307a2e305218 (patch) | |
| tree | 8f27b82a4ab2d5c6554ae31c43cb674a4def2af1 | |
| parent | e84a22027f7a0a962827c8d6be4968a810b042db (diff) | |
Fix CF
ref:29d7ff1c588c276168832b4dbea1f54d8f680e14
| -rw-r--r-- | ydb/library/yql/providers/external_function/cloud_function/actors/cloud_function_transform.cpp | 10 |
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); |
