make the timeout longer

BrandonArp · BrandonArp · commit adb0101bea06 · 2025-07-21T13:28:50.000-07:00
diff --git a/src/test/java/com/arpnetworking/metrics/mad/integration/TelemetryIT.java b/src/test/java/com/arpnetworking/metrics/mad/integration/TelemetryIT.java
@@ -90,7 +90,7 @@ public void testFromSamples() throws InterruptedException, ExecutionException, T
                 }
             }
 
-            Assert.assertEquals(_expectedResult, future.get(5, TimeUnit.SECONDS), 0.0001);
+            Assert.assertEquals(_expectedResult, future.get(30, TimeUnit.SECONDS), 0.0001);
         } finally {
             _telemetryClient.unsubscribe(
                     "TelemetryIT",
@@ -148,7 +148,7 @@ public void testFromAggregatedData() throws InterruptedException, ExecutionExcep
                                 .build());
             }
 
-            Assert.assertEquals(_expectedResult, future.get(5, TimeUnit.SECONDS), 0.0001);
+            Assert.assertEquals(_expectedResult, future.get(30, TimeUnit.SECONDS), 0.0001);
         } finally {
             _telemetryClient.unsubscribe(
                     "TelemetryIT",
@@ -215,7 +215,7 @@ public void testFromMixedSamplesAndAggregatedData() throws InterruptedException,
                                 .build());
             }
 
-            Assert.assertEquals(_expectedResult, future.get(5, TimeUnit.SECONDS), 0.0001);
+            Assert.assertEquals(_expectedResult, future.get(30, TimeUnit.SECONDS), 0.0001);
         } finally {
             _telemetryClient.unsubscribe(
                     "TelemetryIT",

Original file line number	Diff line number	Diff line change
`@@ -90,7 +90,7 @@ public void testFromSamples() throws InterruptedException, ExecutionException, T`
`90`	`90`	`}`
`91`	`91`	`}`
`92`	`92`
`93`		`- Assert.assertEquals(_expectedResult, future.get(5, TimeUnit.SECONDS), 0.0001);`
	`93`	`+ Assert.assertEquals(_expectedResult, future.get(30, TimeUnit.SECONDS), 0.0001);`
`94`	`94`	`} finally {`
`95`	`95`	`_telemetryClient.unsubscribe(`
`96`	`96`	`"TelemetryIT",`
`@@ -148,7 +148,7 @@ public void testFromAggregatedData() throws InterruptedException, ExecutionExcep`
`148`	`148`	`.build());`
`149`	`149`	`}`
`150`	`150`
`151`		`- Assert.assertEquals(_expectedResult, future.get(5, TimeUnit.SECONDS), 0.0001);`
	`151`	`+ Assert.assertEquals(_expectedResult, future.get(30, TimeUnit.SECONDS), 0.0001);`
`152`	`152`	`} finally {`
`153`	`153`	`_telemetryClient.unsubscribe(`
`154`	`154`	`"TelemetryIT",`
`@@ -215,7 +215,7 @@ public void testFromMixedSamplesAndAggregatedData() throws InterruptedException,`
`215`	`215`	`.build());`
`216`	`216`	`}`
`217`	`217`
`218`		`- Assert.assertEquals(_expectedResult, future.get(5, TimeUnit.SECONDS), 0.0001);`
	`218`	`+ Assert.assertEquals(_expectedResult, future.get(30, TimeUnit.SECONDS), 0.0001);`
`219`	`219`	`} finally {`
`220`	`220`	`_telemetryClient.unsubscribe(`
`221`	`221`	`"TelemetryIT",`