From 75d25ff004513f4ca4541f48bbd5efddb652d578 Mon Sep 17 00:00:00 2001
From: Johnny Graettinger <johnny@estuary.dev>
Date: Thu, 2 Nov 2023 15:53:21 -0500
Subject: [PATCH] atf: flush response stream `writer` prior to exit

---
 airbyte-to-flow/src/connector_runner.rs | 1 +
 1 file changed, 1 insertion(+)

diff --git a/airbyte-to-flow/src/connector_runner.rs b/airbyte-to-flow/src/connector_runner.rs
index b090378a5e1b..0f8f93a05ea3 100644
--- 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)