diff --git a/pom.xml b/pom.xml
index f1c08779..dc278d7d 100644
--- a/pom.xml
+++ b/pom.xml
@@ -89,7 +89,7 @@
     <logback.version>1.5.18</logback.version>
     <logback.steno.version>2.2.0</logback.steno.version>
     <log4j.over.slf4j.version>2.0.17</log4j.over.slf4j.version>
-    <metrics.aggregator.protocol.prometheus.version>1.2.0</metrics.aggregator.protocol.prometheus.version>
+    <metrics.aggregator.protocol.prometheus.version>1.2.1</metrics.aggregator.protocol.prometheus.version>
     <metrics.aggregator.protocol.version>1.3.0</metrics.aggregator.protocol.version>
     <metrics.client.version>0.13.0</metrics.client.version>
     <metrics.client.http.version>0.14.0</metrics.client.http.version>
diff --git a/src/test/java/com/arpnetworking/metrics/mad/integration/TelemetryIT.java b/src/test/java/com/arpnetworking/metrics/mad/integration/TelemetryIT.java
index 7dc4b00b..66e7ab30 100644
--- a/src/test/java/com/arpnetworking/metrics/mad/integration/TelemetryIT.java
+++ b/src/test/java/com/arpnetworking/metrics/mad/integration/TelemetryIT.java
@@ -83,7 +83,7 @@ public void testFromSamples() throws InterruptedException, ExecutionException, T
                     future::complete);
 
             // Wait for subscription to be registered and align with aggregation period
-            Thread.sleep(1000);
+            Thread.sleep(3000);
             sleepToBeginningOfSecond();
 
             try (Metrics metrics = METRICS_FACTORY.create()) {
@@ -116,7 +116,7 @@ public void testFromAggregatedData() throws InterruptedException, ExecutionExcep
                     future::complete);
 
             // Wait for subscription to be registered
-            Thread.sleep(1000);
+            Thread.sleep(3000);
             sleepToBeginningOfSecond();
 
             try (Metrics metrics = METRICS_FACTORY.create()) {
@@ -175,7 +175,7 @@ public void testFromMixedSamplesAndAggregatedData() throws InterruptedException,
                     future::complete);
 
             // Wait for subscription to be registered
-            Thread.sleep(1000);
+            Thread.sleep(3000);
             sleepToBeginningOfSecond();
 
             // First mixed samples-aggregates unit of work