Skip to content

Commit d1af5ea

Browse files
committed
Fix linting
Signed-off-by: Dom Del Nano <ddelnano@gmail.com>
1 parent 11234fb commit d1af5ea

File tree

1 file changed

+16
-20
lines changed

1 file changed

+16
-20
lines changed

src/carnot/exec/otel_export_sink_node_test.cc

Lines changed: 16 additions & 20 deletions
Original file line numberDiff line numberDiff line change
@@ -1738,16 +1738,14 @@ TEST_F(OTelExportSinkNodeTest, consume_spans_clears_span_responses) {
17381738
EXPECT_CALL(*trace_mock_, Export(_, _, _))
17391739
.Times(::testing::AtLeast(2))
17401740
.WillOnce(DoAll(SetArgPointee<2>(error_response), Return(grpc::Status::OK)))
1741-
.WillRepeatedly(Invoke(
1742-
[&](const auto&, const auto&, auto* response) {
1743-
1744-
// It's expected that the response argument provided to Export
1745-
// has .Clear() called on it. This CALL assertion verifies that the
1746-
// response object no longer has rejected data points since it should
1747-
// have been .Clear()'ed at the beginning of the second ConsumeTraces invocation
1748-
EXPECT_TRUE(response->partial_success().rejected_spans() == 0);
1749-
return grpc::Status::OK;
1750-
}));
1741+
.WillRepeatedly(Invoke([&](const auto&, const auto&, auto* response) {
1742+
// It's expected that the response argument provided to Export
1743+
// has .Clear() called on it. This CALL assertion verifies that the
1744+
// response object no longer has rejected data points since it should
1745+
// have been .Clear()'ed at the beginning of the second ConsumeTraces invocation
1746+
EXPECT_EQ(response->partial_success().rejected_spans(), 0);
1747+
return grpc::Status::OK;
1748+
}));
17511749

17521750
planpb::OTelExportSinkOperator otel_sink_op;
17531751

@@ -1794,16 +1792,14 @@ TEST_F(OTelExportSinkNodeTest, metrics_response_is_cleared) {
17941792
EXPECT_CALL(*metrics_mock_, Export(_, _, _))
17951793
.Times(::testing::AtLeast(2))
17961794
.WillOnce(DoAll(SetArgPointee<2>(error_response), Return(grpc::Status::OK)))
1797-
.WillRepeatedly(Invoke(
1798-
[&](const auto&, const auto&, auto* response) {
1799-
1800-
// It's expected that the response argument provided to Export
1801-
// has .Clear() called on it. This CALL assertion verifies that the
1802-
// response object no longer has rejected data points since it should
1803-
// have been .Clear()'ed at the beginning of the second ConsumeMetrics invocation
1804-
EXPECT_TRUE(response->partial_success().rejected_data_points() == 0);
1805-
return grpc::Status::OK;
1806-
}));
1795+
.WillRepeatedly(Invoke([&](const auto&, const auto&, auto* response) {
1796+
// It's expected that the response argument provided to Export
1797+
// has .Clear() called on it. This CALL assertion verifies that the
1798+
// response object no longer has rejected data points since it should
1799+
// have been .Clear()'ed at the beginning of the second ConsumeMetrics invocation
1800+
EXPECT_EQ(response->partial_success().rejected_data_points(), 0);
1801+
return grpc::Status::OK;
1802+
}));
18071803

18081804
planpb::OTelExportSinkOperator otel_sink_op;
18091805

0 commit comments

Comments
 (0)