airbyte-to-flow: update flow dependencies

estuary · Dec 4, 2023 · ea8d41e · ea8d41e
1 parent 2c6de4a
commit ea8d41e
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 11 deletions.
diff --git a/airbyte-to-flow/Cargo.lock b/airbyte-to-flow/Cargo.lock
diff --git a/airbyte-to-flow/src/libs/stream.rs b/airbyte-to-flow/src/libs/stream.rs
@@ -17,11 +17,9 @@ pub fn stream_lines(
     in_stream: InterceptorStream,
 ) -> impl TryStream<Item = Result<Bytes, Error>, Error = Error, Ok = bytes::Bytes> {
     io_stream_to_interceptor_stream(
-        AsyncByteLines::new(StreamReader::new(
-            in_stream,
-        ))
-        .into_stream()
-        .map_ok(Bytes::from),
+        AsyncByteLines::new(StreamReader::new(in_stream))
+            .into_stream()
+            .map_ok(Bytes::from),
     )
 }
 
@@ -261,6 +259,7 @@ mod test {
                 resource_config_json: "{}".to_string(),
                 collection: None,
                 field_config_json_map: BTreeMap::new(),
+                backfill: 7,
             }],
         };