Temp fix flaky test for BatchSpanprocessors (#2671)

cijothomas · web-flow · commit eca1ce87084c · 2025-02-15T10:26:53.000-08:00
diff --git a/opentelemetry-sdk/src/trace/span_processor.rs b/opentelemetry-sdk/src/trace/span_processor.rs
@@ -1268,7 +1268,7 @@ mod tests {
             processor.on_end(span);
         }
 
-        tokio::time::sleep(Duration::from_millis(200)).await;
+        tokio::time::sleep(Duration::from_millis(1000)).await;
 
         let exported_spans = exporter_shared.lock().unwrap();
         assert_eq!(exported_spans.len(), 4);
@@ -1292,7 +1292,7 @@ mod tests {
             processor.on_end(span);
         }
 
-        tokio::time::sleep(Duration::from_millis(200)).await;
+        tokio::time::sleep(Duration::from_millis(1000)).await;
 
         let exported_spans = exporter_shared.lock().unwrap();
         assert_eq!(exported_spans.len(), 4);
@@ -1327,7 +1327,7 @@ mod tests {
         }
 
         // Allow time for batching and export
-        tokio::time::sleep(Duration::from_millis(200)).await;
+        tokio::time::sleep(Duration::from_millis(1000)).await;
 
         // Verify exported spans
         let exported_spans = exporter_shared.lock().unwrap();

Original file line number	Diff line number	Diff line change
`@@ -1268,7 +1268,7 @@ mod tests {`
`1268`	`1268`	`processor.on_end(span);`
`1269`	`1269`	`}`
`1270`	`1270`
`1271`		`- tokio::time::sleep(Duration::from_millis(200)).await;`
	`1271`	`+ tokio::time::sleep(Duration::from_millis(1000)).await;`
`1272`	`1272`
`1273`	`1273`	`let exported_spans = exporter_shared.lock().unwrap();`
`1274`	`1274`	`assert_eq!(exported_spans.len(), 4);`
`@@ -1292,7 +1292,7 @@ mod tests {`
`1292`	`1292`	`processor.on_end(span);`
`1293`	`1293`	`}`
`1294`	`1294`
`1295`		`- tokio::time::sleep(Duration::from_millis(200)).await;`
	`1295`	`+ tokio::time::sleep(Duration::from_millis(1000)).await;`
`1296`	`1296`
`1297`	`1297`	`let exported_spans = exporter_shared.lock().unwrap();`
`1298`	`1298`	`assert_eq!(exported_spans.len(), 4);`
`@@ -1327,7 +1327,7 @@ mod tests {`
`1327`	`1327`	`}`
`1328`	`1328`
`1329`	`1329`	`// Allow time for batching and export`
`1330`		`- tokio::time::sleep(Duration::from_millis(200)).await;`
	`1330`	`+ tokio::time::sleep(Duration::from_millis(1000)).await;`
`1331`	`1331`
`1332`	`1332`	`// Verify exported spans`
`1333`	`1333`	`let exported_spans = exporter_shared.lock().unwrap();`