diff --git a/instrumentation/executors/javaagent/src/test/java/io/opentelemetry/javaagent/instrumentation/executors/ThreadPoolExecutorTest.java b/instrumentation/executors/javaagent/src/test/java/io/opentelemetry/javaagent/instrumentation/executors/ThreadPoolExecutorTest.java
index 4b8f35ac1d..e31d0d2d4f 100644
--- a/instrumentation/executors/javaagent/src/test/java/io/opentelemetry/javaagent/instrumentation/executors/ThreadPoolExecutorTest.java
+++ b/instrumentation/executors/javaagent/src/test/java/io/opentelemetry/javaagent/instrumentation/executors/ThreadPoolExecutorTest.java
@@ -6,6 +6,7 @@
 package io.opentelemetry.javaagent.instrumentation.executors;
 
 import static org.assertj.core.api.Assertions.assertThat;
+import static org.awaitility.Awaitility.await;
 
 import io.opentelemetry.api.baggage.Baggage;
 import io.opentelemetry.context.Scope;
@@ -32,7 +33,7 @@ class ThreadPoolExecutorTest {
     latch.await(10, TimeUnit.SECONDS);
 
     assertThat(executor.sameTaskBefore).isTrue();
-    assertThat(executor.sameTaskAfter).isTrue();
+    await().untilAsserted(() -> assertThat(executor.sameTaskAfter).isTrue());
   }
 
   // class is configured to be instrumented via otel.instrumentation.executors.include