Merge 663c33e into 0cda3de

ydb-platform · Mar 4, 2024 · c806628 · c806628
2 parents 0cda3de + 663c33e
commit c806628
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/ydb/core/fq/libs/control_plane_storage/internal/utils.cpp b/ydb/core/fq/libs/control_plane_storage/internal/utils.cpp
@@ -128,6 +128,11 @@ std::vector<TString> GetMeteringRecords(const TString& statistics, bool billable
             if (auto* ingressNode = graph.second.GetValueByPath("IngressBytes.sum")) {
                 ingress += ingressNode->GetIntegerSafe();
             }
+            // special exclusion for PQ/YDS in YQv1
+            if (auto* pqIngressNode = graph.second.GetValueByPath("TaskRunner.Source=PqSource.Stage=Total.IngressBytes.sum")) {
+                ui64 pqIngress = pqIngressNode->GetIntegerSafe();
+                ingress = ingress > pqIngress ? (ingress - pqIngress) : 0;
+            }
         }
     }