From d20e0a09c3ba1b9b5e350d8888af4d545c516420 Mon Sep 17 00:00:00 2001
From: Amey Chaugule <amey@probablynothinglabs.xyz>
Date: Thu, 7 Nov 2024 13:53:39 -0800
Subject: [PATCH] Cargo fmt

---
 crates/core/src/datasource/kafka/kafka_stream_read.rs          | 2 +-
 .../src/physical_plan/continuous/grouped_window_agg_stream.rs  | 3 +--
 crates/core/src/physical_plan/continuous/streaming_window.rs   | 2 +-
 3 files changed, 3 insertions(+), 4 deletions(-)

diff --git a/crates/core/src/datasource/kafka/kafka_stream_read.rs b/crates/core/src/datasource/kafka/kafka_stream_read.rs
index 80f0f3d..caed655 100644
--- a/crates/core/src/datasource/kafka/kafka_stream_read.rs
+++ b/crates/core/src/datasource/kafka/kafka_stream_read.rs
@@ -7,7 +7,7 @@ use arrow_array::{Array, ArrayRef, PrimitiveArray, RecordBatch, StringArray, Str
 use arrow_schema::{DataType, Field, SchemaRef, TimeUnit};
 use crossbeam::channel;
 use denormalized_orchestrator::channel_manager::{create_channel, get_sender, take_receiver};
-use denormalized_orchestrator::orchestrator::{OrchestrationMessage};
+use denormalized_orchestrator::orchestrator::OrchestrationMessage;
 use futures::executor::block_on;
 use log::{debug, error};
 use serde::{Deserialize, Serialize};
diff --git a/crates/core/src/physical_plan/continuous/grouped_window_agg_stream.rs b/crates/core/src/physical_plan/continuous/grouped_window_agg_stream.rs
index 5f455db..0388a23 100644
--- a/crates/core/src/physical_plan/continuous/grouped_window_agg_stream.rs
+++ b/crates/core/src/physical_plan/continuous/grouped_window_agg_stream.rs
@@ -37,8 +37,7 @@ use datafusion::{
 };
 
 use denormalized_orchestrator::{
-    channel_manager::take_receiver,
-    orchestrator::{OrchestrationMessage},
+    channel_manager::take_receiver, orchestrator::OrchestrationMessage,
 };
 use futures::{executor::block_on, Stream, StreamExt};
 use log::debug;
diff --git a/crates/core/src/physical_plan/continuous/streaming_window.rs b/crates/core/src/physical_plan/continuous/streaming_window.rs
index 9db92f9..c6ea378 100644
--- a/crates/core/src/physical_plan/continuous/streaming_window.rs
+++ b/crates/core/src/physical_plan/continuous/streaming_window.rs
@@ -40,7 +40,7 @@ use datafusion::{
 };
 use denormalized_orchestrator::{
     channel_manager::{create_channel, get_sender},
-    orchestrator::{OrchestrationMessage},
+    orchestrator::OrchestrationMessage,
 };
 use futures::{Stream, StreamExt};
 use tracing::debug;