diff --git a/connector_arrow/Cargo.toml b/connector_arrow/Cargo.toml index 86aeaf6..83555b1 100644 --- a/connector_arrow/Cargo.toml +++ b/connector_arrow/Cargo.toml @@ -26,7 +26,6 @@ arrow = { version = "49", default-features = false } # common optional hex = { version = "0.4", optional = true } fallible-streaming-iterator = { version = "0.1", optional = true } -fallible-iterator = { version = "0.2", optional = true } csv = { version = "1", optional = true } bytes = { version = "1", optional = true } byteorder = { version = "1", optional = true } @@ -48,6 +47,11 @@ version = "0.6.6" default-features = false optional = true +[dependencies.postgres-fallible-iterator] +package = "fallible-iterator" +version = "0.2" # this dep is bound to potgres's transitive dep +optional = true + [dependencies.rusqlite] version = "0.31.0" default-features = false @@ -85,11 +89,11 @@ all = ["src_sqlite", "src_duckdb", "src_postgres", "src_mysql", "src_tiberius"] src_postgres = [ "postgres", "postgres-protocol", + "postgres-fallible-iterator", "csv", "hex", "bytes", "byteorder", - "fallible-iterator", ] src_sqlite = ["rusqlite"] src_duckdb = ["duckdb", "fallible-streaming-iterator"] diff --git a/connector_arrow/src/postgres/protocol_extended.rs b/connector_arrow/src/postgres/protocol_extended.rs index a623a3c..2eadb29 100644 --- a/connector_arrow/src/postgres/protocol_extended.rs +++ b/connector_arrow/src/postgres/protocol_extended.rs @@ -65,7 +65,7 @@ impl<'a> Iterator for PostgresBatchStream<'a> { } struct PostgresRowStream<'a> { - iter: fallible_iterator::Fuse>, + iter: postgres_fallible_iterator::Fuse>, } impl<'a> PostgresRowStream<'a> {