Skip to content

Commit f589c6d

Browse files
committed
Remove dangling limit_per_min from de-rate-limited logs
These log sites were switched from rate_limited_info!/debug! back to plain info!/debug! but kept the now-meaningless `limit_per_min = 1` field, which would have been emitted as a spurious log field. Drop it.
1 parent 4125e27 commit f589c6d

4 files changed

Lines changed: 0 additions & 7 deletions

File tree

quickwit/quickwit-indexing/src/actors/indexer.rs

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -134,7 +134,6 @@ impl IndexerState {
134134
io_controls,
135135
)?;
136136
debug!(
137-
limit_per_min = 1,
138137
split_id=%indexed_split.split_id(),
139138
partition_id=%partition_id,
140139
"new-split"

quickwit/quickwit-indexing/src/actors/indexing_pipeline.rs

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -500,7 +500,6 @@ impl Handler<AssignShards> for IndexingPipeline {
500500
// If it is not, it will be respawned soon, and the shards will be assigned afterward.
501501
if let Some(handles) = &self.handles_opt {
502502
info!(
503-
limit_per_min = 1,
504503
shard_ids=?assign_shards_message.0.shard_ids,
505504
"assigning shards to indexing pipeline"
506505
);

quickwit/quickwit-ingest/src/ingest_v2/state.rs

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -599,7 +599,6 @@ impl FullyLockedIngesterState<'_> {
599599
}
600600
}
601601
info!(
602-
limit_per_min = 1,
603602
"truncated shard `{queue_id}` at {truncate_up_to_position_inclusive} initiated via \
604603
`{initiator}`"
605604
);

quickwit/quickwit-serve/src/lib.rs

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -240,7 +240,6 @@ async fn balance_channel_for_service(
240240
ClusterChange::Add(node) if node.is_service_enabled(service) => {
241241
let chitchat_id = node.chitchat_id();
242242
info!(
243-
limit_per_min = 1,
244243
node_id = %chitchat_id.node_id,
245244
generation_id = chitchat_id.generation_id,
246245
"adding node `{}` to {} pool",
@@ -1122,7 +1121,6 @@ fn build_ingester_insert_change(
11221121
) -> Change<NodeId, IngesterPoolEntry> {
11231122
let chitchat_id = node.chitchat_id();
11241123
info!(
1125-
limit_per_min = 1,
11261124
node_id = %chitchat_id.node_id,
11271125
generation_id = chitchat_id.generation_id,
11281126
"adding/updating node `{}` with ingester status `{}` to ingester pool",
@@ -1211,7 +1209,6 @@ async fn setup_searcher(
12111209
ClusterChange::Add(node) if node.is_searcher() => {
12121210
let chitchat_id = node.chitchat_id();
12131211
info!(
1214-
limit_per_min = 1,
12151212
node_id = %chitchat_id.node_id,
12161213
generation_id = chitchat_id.generation_id,
12171214
"adding node `{}` to searcher pool",
@@ -1358,7 +1355,6 @@ fn build_indexer_insert_change(
13581355
) -> Change<NodeId, IndexerNodeInfo> {
13591356
let chitchat_id = node.chitchat_id();
13601357
info!(
1361-
limit_per_min = 1,
13621358
node_id = %chitchat_id.node_id,
13631359
generation_id = chitchat_id.generation_id,
13641360
"adding node `{}` with ingester status `{}` to indexer pool",

0 commit comments

Comments
 (0)