Skip to content

Commit 1e1fe57

Browse files
authored
test(buffer): Remove flaky test (#5316)
1 parent 35ed884 commit 1e1fe57

File tree

1 file changed

+0
-34
lines changed
  • relay-server/src/services/buffer

1 file changed

+0
-34
lines changed

relay-server/src/services/buffer/mod.rs

Lines changed: 0 additions & 34 deletions
Original file line numberDiff line numberDiff line change
@@ -884,40 +884,6 @@ mod tests {
884884
assert_eq!(envelope_processor_rx.len(), 0);
885885
}
886886

887-
#[tokio::test]
888-
async fn test_sqlite_metrics() {
889-
let EnvelopeBufferServiceResult {
890-
service,
891-
envelope_processor_rx: _envelope_processor_rx,
892-
project_cache_handle: _project_cache_handle,
893-
outcome_aggregator_rx: _outcome_aggregator_rx,
894-
global_tx: _global_tx,
895-
} = envelope_buffer_service(
896-
Some(serde_json::json!({
897-
"spool": {
898-
"envelopes": {
899-
"path": std::env::temp_dir().join(Uuid::new_v4().to_string()),
900-
}
901-
}
902-
})),
903-
global_config::Status::Pending,
904-
);
905-
906-
let addr = service.start_in(&TokioServiceSpawn);
907-
tokio::time::sleep(Duration::from_millis(200)).await;
908-
909-
assert_eq!(addr.metrics.item_count.load(Ordering::Relaxed), 0);
910-
911-
for _ in 0..10 {
912-
let envelope = new_managed_envelope(false, "foo");
913-
addr.addr().send(EnvelopeBuffer::Push(envelope));
914-
}
915-
916-
tokio::time::sleep(Duration::from_millis(1100)).await;
917-
918-
assert_eq!(addr.metrics.item_count.load(Ordering::Relaxed), 10);
919-
}
920-
921887
#[tokio::test(start_paused = true)]
922888
async fn old_envelope_is_dropped() {
923889
let EnvelopeBufferServiceResult {

0 commit comments

Comments
 (0)