From 5a98246f50f38dc29c03042ad6f52b53bbebd132 Mon Sep 17 00:00:00 2001 From: Arthur Silva Sens Date: Sat, 17 May 2025 05:35:26 -0300 Subject: [PATCH] Fix flakiness in TestOTLPWriteHandler (#16608) --- storage/remote/write_test.go | 6 ++---- 1 file changed, 2 insertions(+), 4 deletions(-) diff --git a/storage/remote/write_test.go b/storage/remote/write_test.go index 9d32067a6d..45f2b075ee 100644 --- a/storage/remote/write_test.go +++ b/storage/remote/write_test.go @@ -381,8 +381,8 @@ func TestWriteStorageApplyConfig_PartialUpdate(t *testing.T) { } func TestOTLPWriteHandler(t *testing.T) { - exportRequest := generateOTLPWriteRequest() timestamp := time.Now() + exportRequest := generateOTLPWriteRequest(timestamp) for _, testCase := range []struct { name string otlpCfg config.OTLPConfig @@ -516,15 +516,13 @@ func handleOTLP(t *testing.T, exportRequest pmetricotlp.ExportRequest, otlpCfg c return appendable } -func generateOTLPWriteRequest() pmetricotlp.ExportRequest { +func generateOTLPWriteRequest(timestamp time.Time) pmetricotlp.ExportRequest { d := pmetric.NewMetrics() // Generate One Counter, One Gauge, One Histogram, One Exponential-Histogram // with resource attributes: service.name="test-service", service.instance.id="test-instance", host.name="test-host" // with metric attribute: foo.bar="baz" - timestamp := time.Now() - resourceMetric := d.ResourceMetrics().AppendEmpty() resourceMetric.Resource().Attributes().PutStr("service.name", "test-service") resourceMetric.Resource().Attributes().PutStr("service.instance.id", "test-instance")