Skip to content

Commit 2e735ae

Browse files
committed
core: Remove some more logs
The log in stream_aggregator can become very spammy with a small block range The log in monitor isn't really needed since surrounding code already logs enough information
1 parent de7ec8f commit 2e735ae

2 files changed

Lines changed: 0 additions & 9 deletions

File tree

core/src/amp_subgraph/monitor.rs

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -188,10 +188,6 @@ impl Monitor {
188188
loop {
189189
tokio::select! {
190190
Some(command) = command_rx.recv() => {
191-
debug!(logger, "Processing a new command";
192-
"command" => ?command
193-
);
194-
195191
match &command {
196192
Command::Start { .. } => {
197193
Self::process_start_command(

graph/src/amp/stream_aggregator/mod.rs

Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -101,11 +101,6 @@ impl StreamAggregator {
101101

102102
let num_streams = named_streams.len();
103103

104-
info!(logger, "Initializing stream aggregator";
105-
"num_streams" => num_streams,
106-
"max_buffer_size" => max_buffer_size
107-
);
108-
109104
Self {
110105
named_streams,
111106
buffer: Buffer::new(num_streams, max_buffer_size),

0 commit comments

Comments
 (0)