aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorhcpp <hcpp@ydb.tech>2023-04-18 17:23:46 +0300
committerhcpp <hcpp@ydb.tech>2023-04-18 17:23:46 +0300
commit4d12f240b9bc7a2b200f0550199646bb6034f2d6 (patch)
tree8bf51710204514e6d3379a7b159f7146f64c7f4b
parent6638fc866fe70c557e5c1a4c3c89eb2f55db0700 (diff)
downloadydb-4d12f240b9bc7a2b200f0550199646bb6034f2d6.tar.gz
filling in the response for each event
-rw-r--r--ydb/core/fq/libs/cloud_audit/yq_cloud_audit_service.cpp9
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());