chore: fix clippy.

databendlabs · Sep 26, 2022 · 9175f98 · 9175f98
1 parent 79d1e1d
commit 9175f98
Showing 1 changed file with 3 additions and 5 deletions.
diff --git a/src/query/pipeline/sources/src/processors/sources/input_formats/source_deserializer.rs b/src/query/pipeline/sources/src/processors/sources/input_formats/source_deserializer.rs
@@ -83,12 +83,10 @@ impl<I: InputFormatPipe> Processor for DeserializeSource<I> {
                 None => {
                     if self.input_buffer.is_some() {
                         Ok(Event::Sync)
+                    } else if self.input_finished {
+                        Ok(Event::Finished)
                     } else {
-                        if self.input_finished {
-                            Ok(Event::Finished)
-                        } else {
-                            Ok(Event::Async)
-                        }
+                        Ok(Event::Async)
                     }
                 }
             }