Update src/connectors/impls/gcs/streamer.rs
@@ -391,11 +391,11 @@ impl GCSWriterSink {
} else {
None
};
- return self.finish_upload(contraflow_data).await;
- }
-
+ self.finish_upload(contraflow_data).await
+ } else {
Ok(())
}
+ }
async fn finish_upload(&mut self, contraflow_data: Option<ContraflowData>) -> Result<()> {
if let Some(current_name) = self.current_name.as_ref() {
