diff --git a/test/e2e/density.go b/test/e2e/density.go
index b6c53efa6a9..30639cacca3 100644
--- a/test/e2e/density.go
+++ b/test/e2e/density.go
@@ -85,9 +85,8 @@ var _ = Describe("Density", func() {
 		expectNoError(writePerfData(c, fmt.Sprintf(testContext.OutputDir+"/%s", uuid), "after"))
 
 		// Verify latency metrics
-		// TODO: Update threshold to 1s once we reach this goal
 		// TODO: We should reset metrics before the test. Currently previous tests influence latency metrics.
-		highLatencyRequests, err := HighLatencyRequests(c, 3*time.Second, util.NewStringSet("events"))
+		highLatencyRequests, err := HighLatencyRequests(c, 2*time.Second, util.NewStringSet("events"))
 		expectNoError(err)
 		Expect(highLatencyRequests).NotTo(BeNumerically(">", 0))
 	})
diff --git a/test/e2e/load.go b/test/e2e/load.go
index a8577ae4ed2..dc3b30ac36d 100644
--- a/test/e2e/load.go
+++ b/test/e2e/load.go
@@ -78,9 +78,8 @@ var _ = Describe("Load capacity", func() {
 		}
 
 		// Verify latency metrics
-		// TODO: Update threshold to 1s once we reach this goal
 		// TODO: We should reset metrics before the test. Currently previous tests influence latency metrics.
-		highLatencyRequests, err := HighLatencyRequests(c, 3*time.Second, util.NewStringSet("events"))
+		highLatencyRequests, err := HighLatencyRequests(c, 1*time.Second, util.NewStringSet("events"))
 		expectNoError(err, "Too many instances metrics above the threshold")
 		Expect(highLatencyRequests).NotTo(BeNumerically(">", 0))
 	})