diff --git a/src/kfs_frontend/kfs_graph_executor_impl.cpp b/src/kfs_frontend/kfs_graph_executor_impl.cpp index 6905539a0c..e668939d96 100644 --- a/src/kfs_frontend/kfs_graph_executor_impl.cpp +++ b/src/kfs_frontend/kfs_graph_executor_impl.cpp @@ -15,12 +15,12 @@ //***************************************************************************** #include "kfs_graph_executor_impl.hpp" +#include #include #include #include #include #include -#include #include "../kfs_frontend/kfs_utils.hpp" #include "../logging.hpp" diff --git a/src/model_metric_reporter.cpp b/src/model_metric_reporter.cpp index c90f25886f..45923a8a9f 100644 --- a/src/model_metric_reporter.cpp +++ b/src/model_metric_reporter.cpp @@ -592,12 +592,12 @@ MediapipeServableMetricReporter::MediapipeServableMetricReporter(const MetricCon // KFS this->requestLatencyGrpcModelInferStream = family->addMetric({{"name", graphName}, - {"method", "ModelInferStream"}}, + {"method", "ModelInferStream"}}, this->buckets); THROW_IF_NULL(this->requestLatencyGrpcModelInferStream, "cannot create metric"); // V3 this->requestLatencyRestV3Stream = family->addMetric({{"name", graphName}, - {"method", "Stream"}}, + {"method", "Stream"}}, this->buckets); THROW_IF_NULL(this->requestLatencyRestV3Stream, "cannot create metric"); } diff --git a/src/model_metric_reporter.hpp b/src/model_metric_reporter.hpp index 861e7e0de2..f2238d7e7f 100644 --- a/src/model_metric_reporter.hpp +++ b/src/model_metric_reporter.hpp @@ -217,14 +217,12 @@ class MediapipeServableMetricReporter { std::unique_ptr requestLatencyGrpcModelInferStream; std::unique_ptr requestLatencyRestV3Stream; - inline MetricHistogram* getRequestLatencyMetric(const ExecutionContext& context) { if (context.method == ExecutionContext::Method::ModelInferStream) return this->requestLatencyGrpcModelInferStream.get(); if (context.method == ExecutionContext::Method::V3Stream) return this->requestLatencyRestV3Stream.get(); return nullptr; - } inline MetricHistogram* getProcessingTimeMetric(const ExecutionContext& context) { diff --git a/src/test/streaming_test.cpp b/src/test/streaming_test.cpp index 6178b22e4d..5f924e3af2 100644 --- a/src/test/streaming_test.cpp +++ b/src/test/streaming_test.cpp @@ -1615,7 +1615,7 @@ node { } TEST_F(StreamingTest, AutomaticTimestampingExceedsMax) { - GTEST_SKIP() << "TODO"; + GTEST_SKIP() << "TODO"; #ifdef _WIN32 GTEST_SKIP() << "Test disabled on windows"; #endif