diff --git a/nexus/catalog/src/lib.rs b/nexus/catalog/src/lib.rs index 3c50ab84ed..f498992a9f 100644 --- a/nexus/catalog/src/lib.rs +++ b/nexus/catalog/src/lib.rs @@ -6,7 +6,7 @@ use peer_postgres::{self, ast}; use pgwire::error::PgWireResult; use postgres_connection::{connect_postgres, get_pg_connection_string}; use pt::{ - flow_model::{FlowJob, QRepFlowJob}, + flow_model::QRepFlowJob, peerdb_peers::PostgresConfig, peerdb_peers::{peer::Config, DbType, Peer}, prost::Message, diff --git a/nexus/flow-rs/src/grpc.rs b/nexus/flow-rs/src/grpc.rs index 31333dc903..a07115c1ec 100644 --- a/nexus/flow-rs/src/grpc.rs +++ b/nexus/flow-rs/src/grpc.rs @@ -176,7 +176,6 @@ impl FlowGrpcClient { script: job.script.clone(), system: system as i32, idle_timeout_seconds: job.sync_interval.unwrap_or_default(), - ..Default::default() }; self.start_peer_flow(flow_conn_cfg).await