Skip to content

Commit

Permalink
Remove unnecessary flush from tests (#1622)
Browse files Browse the repository at this point in the history
  • Loading branch information
cijothomas authored Mar 15, 2024
1 parent 9f0ac7d commit a4fae95
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 9 deletions.
2 changes: 0 additions & 2 deletions opentelemetry-sdk/src/logs/mod.rs
Original file line number Diff line number Diff line change
Expand Up @@ -38,8 +38,6 @@ mod tests {
log_record.attributes = Some(attributes);
logger.emit(log_record);

logger_provider.force_flush();

// Assert
let exported_logs = exporter
.get_emitted_logs()
Expand Down
11 changes: 4 additions & 7 deletions opentelemetry-sdk/src/trace/mod.rs
Original file line number Diff line number Diff line change
Expand Up @@ -80,8 +80,6 @@ mod tests {
span.add_event("test-event".to_string(), vec![]);
});

provider.force_flush();

// Assert
let exported_spans = exporter
.get_finished_spans()
Expand Down Expand Up @@ -112,8 +110,10 @@ mod tests {
span.set_attribute(KeyValue::new("attribute1", "value1"));
span.add_event("test-event".to_string(), vec![]);
span.set_status(Status::error("cancelled"));
drop(span);
provider.force_flush();
span.end();

// After span end, further operations should not have any effect
span.update_name("span_name_updated");

// Assert
let exported_spans = exporter
Expand Down Expand Up @@ -150,7 +150,6 @@ mod tests {
span.add_event("test-event".to_string(), vec![]);
span.set_status(Status::Ok);
drop(span);
provider.force_flush();

// Assert
let exported_spans = exporter
Expand Down Expand Up @@ -197,7 +196,6 @@ mod tests {
let span_builder = SpanBuilder::from_name("span_name").with_links(links);
let mut span = tracer.build(span_builder);
span.end();
provider.force_flush();

// Assert
let exported_spans = exporter
Expand Down Expand Up @@ -233,7 +231,6 @@ mod tests {
span.add_event("test event again, after span builder", Vec::new());
span.add_event("test event once again, after span builder", Vec::new());
span.end();
provider.force_flush();

// Assert
let exported_spans = exporter
Expand Down

0 comments on commit a4fae95

Please sign in to comment.