diff --git a/src/net/live_fluereflow.rs b/src/net/live_fluereflow.rs
index be8d0d1..b66f435 100644
--- a/src/net/live_fluereflow.rs
+++ b/src/net/live_fluereflow.rs
@@ -293,7 +293,7 @@ pub async fn online_packet_capture(arg: Args) -> Result<(), FluereError> {
                     for (key, flow) in active_flow_guard.iter() {
                         if flow_timeout > 0 && flow.last < (time - (flow_timeout * 1000)) {
                             trace!("flow expired");
-                            
+
                             //plugin_manager.process_flow_data(*flow).await.unwrap();
                             records.push(*flow);
                             expired_flows.push(*key);
@@ -319,7 +319,7 @@ pub async fn online_packet_capture(arg: Args) -> Result<(), FluereError> {
                     let cloned_records = records.clone();
                     records.clear();
                     //let tasks = task::spawn(async {
-                        //fluere_exporter(cloned_records, file).await;
+                    //fluere_exporter(cloned_records, file).await;
                     //});
                     let file_path_clone = file_path.clone();
                     export_tasks.push(task::spawn(async move {
@@ -327,9 +327,6 @@ pub async fn online_packet_capture(arg: Args) -> Result<(), FluereError> {
                         debug!("Export {} Finished", file_path_clone);
                     }));
 
-
-
-
                     /*if verbose >= 1 {
                     println!("Export {} result: {:?}", file_path, result);
                     }*/
diff --git a/src/net/online_fluereflow.rs b/src/net/online_fluereflow.rs
index b4358b2..14bde95 100644
--- a/src/net/online_fluereflow.rs
+++ b/src/net/online_fluereflow.rs
@@ -213,9 +213,15 @@ pub async fn packet_capture(arg: Args) -> Result<(), FluereError> {
                     let cloned_plugin_manager = plugin_manager.clone();
                     tasks.push(task::spawn(async move {
                         for flow in &expired_flow_data {
-                            cloned_plugin_manager.process_flow_data(*flow).await.unwrap();
+                            cloned_plugin_manager
+                                .process_flow_data(*flow)
+                                .await
+                                .unwrap();
                         }
-                        debug!("Sending {} expired flows to plugins done", expired_flow_data.len());
+                        debug!(
+                            "Sending {} expired flows to plugins done",
+                            expired_flow_data.len()
+                        );
                     }));
 
                     active_flow.retain(|key, _| !expired_flows.contains(key));