Skip to content

Commit

Permalink
style
Browse files Browse the repository at this point in the history
  • Loading branch information
bstrzele committed Jan 31, 2025
1 parent b4a02c3 commit bcb27b1
Show file tree
Hide file tree
Showing 4 changed files with 4 additions and 6 deletions.
2 changes: 1 addition & 1 deletion src/kfs_frontend/kfs_graph_executor_impl.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -15,12 +15,12 @@
//*****************************************************************************
#include "kfs_graph_executor_impl.hpp"

#include <chrono>
#include <sstream>
#include <string>
#include <unordered_map>
#include <utility>
#include <vector>
#include <chrono>

#include "../kfs_frontend/kfs_utils.hpp"
#include "../logging.hpp"
Expand Down
4 changes: 2 additions & 2 deletions src/model_metric_reporter.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -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");
}
Expand Down
2 changes: 0 additions & 2 deletions src/model_metric_reporter.hpp
Original file line number Diff line number Diff line change
Expand Up @@ -217,14 +217,12 @@ class MediapipeServableMetricReporter {
std::unique_ptr<MetricHistogram> requestLatencyGrpcModelInferStream;
std::unique_ptr<MetricHistogram> 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) {
Expand Down
2 changes: 1 addition & 1 deletion src/test/streaming_test.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -1615,7 +1615,7 @@ node {
}

TEST_F(StreamingTest, AutomaticTimestampingExceedsMax) {
GTEST_SKIP() << "TODO";
GTEST_SKIP() << "TODO";
#ifdef _WIN32
GTEST_SKIP() << "Test disabled on windows";
#endif
Expand Down

0 comments on commit bcb27b1

Please sign in to comment.