diff --git a/src/connector/src/connector_common/postgres.rs b/src/connector/src/connector_common/postgres.rs index 2701ec142b929..73c8241aae83e 100644 --- a/src/connector/src/connector_common/postgres.rs +++ b/src/connector/src/connector_common/postgres.rs @@ -30,6 +30,7 @@ use thiserror_ext::AsReport; use tokio_postgres::types::Kind as PgKind; use tokio_postgres::{Client as PgClient, NoTls}; +#[cfg(not(madsim))] use super::maybe_tls_connector::MaybeMakeTlsConnector; use crate::error::ConnectorResult; diff --git a/src/connector/src/source/cdc/external/postgres.rs b/src/connector/src/source/cdc/external/postgres.rs index d3684030030bf..ecc503934bb69 100644 --- a/src/connector/src/source/cdc/external/postgres.rs +++ b/src/connector/src/source/cdc/external/postgres.rs @@ -26,7 +26,6 @@ use serde_derive::{Deserialize, Serialize}; use tokio_postgres::types::PgLsn; use crate::connector_common::create_pg_client; -#[cfg(not(madsim))] use crate::error::{ConnectorError, ConnectorResult}; use crate::parser::postgres_row_to_owned_row; use crate::parser::scalar_adapter::ScalarAdapter;