Bump itertools from 0.12.1 to 0.13.0 in /quickwit (#5102)

* Bump itertools from 0.12.1 to 0.13.0 in /quickwit

Bumps [itertools](https://github.com/rust-itertools/itertools) from 0.12.1 to 0.13.0.
- [Changelog](https://github.com/rust-itertools/itertools/blob/master/CHANGELOG.md)
- [Commits](rust-itertools/itertools@v0.12.1...v0.13.0)

---
updated-dependencies:
- dependency-name: itertools
  dependency-type: direct:production
  update-type: version-update:semver-minor
...

Signed-off-by: dependabot[bot] <[email protected]>

* Replace deprecated `group_by` with `chunk_by`

---------

Signed-off-by: dependabot[bot] <[email protected]>
Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
Co-authored-by: Adrien Guillo <[email protected]>

quickwit/Cargo.toml

@@ -134,7 +134,7 @@ hyper = { version = "0.14", features = [
 hyper-rustls = "0.24"
 indexmap = { version = "2.1.0", features = ["serde"] }
 indicatif = "0.17.3"
-itertools = "0.12"
+itertools = "0.13"
 json_comments = "0.2"
 libz-sys = "1.1.8"
 lru = "0.12"

quickwit/quickwit-cluster/src/cluster.rs

@@ -1113,13 +1113,13 @@ mod tests {
         let node_grouped_tasks: HashMap<IndexingTask, usize> = node
             .indexing_tasks
             .iter()
-            .group_by(|task| (*task).clone())
+            .chunk_by(|task| (*task).clone())
             .into_iter()
             .map(|(key, group)| (key, group.count()))
             .collect();
         let grouped_tasks: HashMap<IndexingTask, usize> = indexing_tasks
             .iter()
-            .group_by(|task| (*task).clone())
+            .chunk_by(|task| (*task).clone())
             .into_iter()
             .map(|(key, group)| (key, group.count()))
             .collect();

quickwit/quickwit-control-plane/src/indexing_scheduler/mod.rs

@@ -501,13 +501,13 @@ fn get_indexing_tasks_diff<'a>(
     let mut unplanned_tasks: Vec<&IndexingTask> = Vec::new();
     let grouped_running_tasks: FnvHashMap<&IndexingTask, usize> = running_tasks
         .iter()
-        .group_by(|&task| task)
+        .chunk_by(|&task| task)
         .into_iter()
         .map(|(key, group)| (key, group.count()))
         .collect();
     let grouped_last_applied_tasks: FnvHashMap<&IndexingTask, usize> = last_applied_tasks
         .iter()
-        .group_by(|&task| task)
+        .chunk_by(|&task| task)
         .into_iter()
         .map(|(key, group)| (key, group.count()))
         .collect();

quickwit/quickwit-search/src/fetch_docs.rs

@@ -62,7 +62,7 @@ async fn fetch_docs_to_map(
     global_doc_addrs.sort_by(|a, b| a.split.cmp(&b.split));
     for (split_id, global_doc_addrs) in global_doc_addrs
         .iter()
-        .group_by(|global_doc_addr| global_doc_addr.split.as_str())
+        .chunk_by(|global_doc_addr| global_doc_addr.split.as_str())
         .into_iter()
     {
         let global_doc_addrs: Vec<GlobalDocAddress> =

quickwit/quickwit-serve/src/jaeger_api/model.rs

@@ -33,7 +33,7 @@ pub(super) const DEFAULT_NUMBER_OF_TRACES: i32 = 20;
 pub(super) fn build_jaeger_traces(spans: Vec<JaegerSpan>) -> anyhow::Result<Vec<JaegerTrace>> {
     let jaeger_traces: Vec<JaegerTrace> = spans
         .into_iter()
-        .group_by(|span| span.trace_id.clone())
+        .chunk_by(|span| span.trace_id.clone())
         .into_iter()
         .map(|(span_id, group)| JaegerTrace::new(span_id, group.collect()))
         .collect();