We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 6889344 commit a72f713Copy full SHA for a72f713
1 file changed
bottlecap/src/logs/agent.rs
@@ -65,10 +65,8 @@ impl LogsAgent {
65
Some((request_id, execution_id, execution_name)) = self.durable_context_rx.recv() => {
66
self.processor.insert_to_durable_map(&request_id, &execution_id, &execution_name);
67
let ready_logs = self.processor.take_ready_logs();
68
- if !ready_logs.is_empty() {
69
- if let Err(e) = self.aggregator_handle.insert_batch(ready_logs) {
70
- error!("LOGS_AGENT | Failed to insert batch: {}", e);
71
- }
+ if !ready_logs.is_empty() && let Err(e) = self.aggregator_handle.insert_batch(ready_logs) {
+ error!("LOGS_AGENT | Failed to insert batch: {}", e);
72
}
73
74
() = self.cancel_token.cancelled() => {
0 commit comments