atf: flush response stream writer prior to exit

estuary · Nov 2, 2023 · 75d25ff · 75d25ff
1 parent 06b7fba
commit 75d25ff
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/airbyte-to-flow/src/connector_runner.rs b/airbyte-to-flow/src/connector_runner.rs
@@ -274,6 +274,7 @@ async fn streaming_all(
                 Err(e) => Err::<(), std::io::Error>(e.into())?,
             }
         }
+        writer.flush().await?;
 
         response_finished_sender
             .send(true)