diff options
author | aozeritsky <aozeritsky@yandex-team.ru> | 2022-04-12 21:52:00 +0300 |
---|---|---|
committer | aozeritsky <aozeritsky@yandex-team.ru> | 2022-04-12 21:52:00 +0300 |
commit | c7d63f15485bbd5f09d3d85d40d7172768c5a63f (patch) | |
tree | b4d9a6c3af5c5312b89d6901ec67ac501e596c4d | |
parent | 26fffc7fdd4e9d77ecf2d1216701a725bac9aa07 (diff) | |
download | ydb-c7d63f15485bbd5f09d3d85d40d7172768c5a63f.tar.gz |
YQL-13675: Rename retry counter
ref:455c58a17a88a5e686df8fc165ffa6415914b7fa
-rw-r--r-- | ydb/library/yql/providers/dq/service/grpc_service.cpp | 7 |
1 files changed, 4 insertions, 3 deletions
diff --git a/ydb/library/yql/providers/dq/service/grpc_service.cpp b/ydb/library/yql/providers/dq/service/grpc_service.cpp index b10537591c..824c74fa60 100644 --- a/ydb/library/yql/providers/dq/service/grpc_service.cpp +++ b/ydb/library/yql/providers/dq/service/grpc_service.cpp @@ -59,6 +59,7 @@ namespace NYql::NDqs { class TServiceProxyActor: public TSynchronizableRichActor<TServiceProxyActor<RequestType, ResponseType>> { public: static constexpr char ActorName[] = "SERVICE_PROXY"; + static constexpr char RetryName[] = "OperationRetry"; explicit TServiceProxyActor( NGrpc::IRequestContextBase* ctx, @@ -69,7 +70,7 @@ namespace NYql::NDqs { , Counters(counters) , ServiceProxyActorCounters(counters->GetSubgroup("component", "ServiceProxyActor")) , ClientDisconnectedCounter(ServiceProxyActorCounters->GetCounter("ClientDisconnected", /*derivative=*/ true)) - , RetryCounter(ServiceProxyActorCounters->GetCounter("Retry", /*derivative=*/ true)) + , RetryCounter(ServiceProxyActorCounters->GetCounter(RetryName, /*derivative=*/ true)) , FallbackCounter(ServiceProxyActorCounters->GetCounter("Fallback", /*derivative=*/ true)) , ErrorCounter(ServiceProxyActorCounters->GetCounter("UnrecoverableError", /*derivative=*/ true)) , Request(dynamic_cast<const RequestType*>(ctx->GetRequest())) @@ -183,10 +184,10 @@ namespace NYql::NDqs { YQL_LOG(DEBUG) << "TServiceProxyActor::OnReturnResult " << ev->Get()->Record.GetMetric().size(); QueryStat.AddCounters(ev->Get()->Record); if (ev->Get()->Record.GetIssues().size() > 0 && ev->Get()->Record.GetRetriable() && Retry < MaxRetries) { - QueryStat.AddCounter("Retry", TDuration::MilliSeconds(0)); + QueryStat.AddCounter(RetryName, TDuration::MilliSeconds(0)); NYql::TIssues issues; NYql::IssuesFromMessage(ev->Get()->Record.GetIssues(), issues); - YQL_LOG(WARN) << "Retry " << Retry << " Issues: " << issues.ToString(); + YQL_LOG(WARN) << RetryName << " " << Retry << " Issues: " << issues.ToString(); DoRetry(); } else { if (ev->Get()->Record.GetIssues().size() > 0) { |