always forget to format
@@ -23,8 +23,8 @@ use futures_retry::{FutureRetry,
RetryPolicy};
use grapl_utils::iter_ext::GraplIterExt;
use log::{error,
- warn,
- info};
+ info,
+ warn};
use crate::{graph_description::{Edge,
EdgeList,
@@ -130,11 +130,13 @@ impl Graph {
.map(|(_, node)| node.generate_upsert_components())
.collect();
- let _: Vec<MutationResponse> =
- futures::stream::iter(node_upserts.into_iter().chunks_owned(DGRAPH_UPSERT_CHUNK_SIZE))
+ let _: Vec<MutationResponse> = futures::stream::iter(
+ node_upserts
+ .into_iter()
+ .chunks_owned(DGRAPH_UPSERT_CHUNK_SIZE),
+ )
.map(|upsert_chunk| {
- let (query_blocks, mutation_units): (Vec<_>, Vec<_>) =
- upsert_chunk.into_iter().unzip();
+ let (query_blocks, mutation_units): (Vec<_>, Vec<_>) = upsert_chunk.into_iter().unzip();
let query = QueryBuilder::default()
.query_blocks(query_blocks)
