diff options
author | hcpp <hcpp@ydb.tech> | 2023-04-18 17:23:46 +0300 |
---|---|---|
committer | hcpp <hcpp@ydb.tech> | 2023-04-18 17:23:46 +0300 |
commit | 4d12f240b9bc7a2b200f0550199646bb6034f2d6 (patch) | |
tree | 8bf51710204514e6d3379a7b159f7146f64c7f4b | |
parent | 6638fc866fe70c557e5c1a4c3c89eb2f55db0700 (diff) | |
download | ydb-4d12f240b9bc7a2b200f0550199646bb6034f2d6.tar.gz |
filling in the response for each event
-rw-r--r-- | ydb/core/fq/libs/cloud_audit/yq_cloud_audit_service.cpp | 9 |
1 files changed, 4 insertions, 5 deletions
diff --git a/ydb/core/fq/libs/cloud_audit/yq_cloud_audit_service.cpp b/ydb/core/fq/libs/cloud_audit/yq_cloud_audit_service.cpp index 77b20c6151..d42807718a 100644 --- a/ydb/core/fq/libs/cloud_audit/yq_cloud_audit_service.cpp +++ b/ydb/core/fq/libs/cloud_audit/yq_cloud_audit_service.cpp @@ -135,11 +135,10 @@ void FillResponse(TEvent& cloudEvent, const NYql::TIssues& issues) { ? yandex::cloud::events::EventStatus::DONE : yandex::cloud::events::EventStatus::ERROR); - if (issues.Empty()) { - cloudEvent.mutable_response(); - //auto* response = cloudEvent.mutable_response(); - //response->set_operation_id(response->operation_id()); - } else { + // response field must always be filled + cloudEvent.mutable_response(); + + if (issues) { auto* error = cloudEvent.mutable_error(); error->set_code(grpc::StatusCode::UNKNOWN); error->set_message(issues.ToString()); |