From eaea4fa3a715109448db5368b3a7f6f5c85834c5 Mon Sep 17 00:00:00 2001
From: Paul Scoropan <1paulscoropan@gmail.com>
Date: Wed, 20 Nov 2024 15:40:33 -0500
Subject: [PATCH] rebase formatting

Signed-off-by: Paul Scoropan <1paulscoropan@gmail.com>
---
 src/orchestrator/streaming.rs | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git a/src/orchestrator/streaming.rs b/src/orchestrator/streaming.rs
index e0aa68ef..3d269f13 100644
--- a/src/orchestrator/streaming.rs
+++ b/src/orchestrator/streaming.rs
@@ -24,7 +24,7 @@ use axum::http::HeaderMap;
 use futures::{future::try_join_all, Stream, StreamExt, TryStreamExt};
 use tokio::sync::{broadcast, mpsc};
 use tokio_stream::wrappers::{BroadcastStream, ReceiverStream};
-use tracing::{debug, warn, error, info, instrument, Instrument, Span};
+use tracing::{debug, error, info, instrument, warn, Instrument, Span};
 
 use super::{get_chunker_ids, Context, Error, Orchestrator, StreamingClassificationWithGenTask};
 use crate::{
@@ -550,7 +550,8 @@ async fn chunk_broadcast_task(
                     }
                 }
             }
-        }.instrument(Span::current())
+        }
+        .instrument(Span::current())
     });
     Ok(chunk_tx)
 }