diff --git a/nexus/peer-cursor/src/util.rs b/nexus/peer-cursor/src/util.rs index e3e4405aa5..e87478d67b 100644 --- a/nexus/peer-cursor/src/util.rs +++ b/nexus/peer-cursor/src/util.rs @@ -88,7 +88,7 @@ pub fn records_to_query_response<'a>(records: Records) -> PgWireResult> = Arc::new(records.schema.fields.clone()); let schema_copy = pg_schema.clone(); - let data_row_stream = stream::iter(records.records.into_iter()) + let data_row_stream = stream::iter(records.records) .map(move |record| { let mut encoder = DataRowEncoder::new(schema_copy.clone()); for value in record.values.iter() { diff --git a/nexus/server/src/main.rs b/nexus/server/src/main.rs index cafe2084f4..20ff95daf3 100644 --- a/nexus/server/src/main.rs +++ b/nexus/server/src/main.rs @@ -150,10 +150,10 @@ impl NexusBackend { } fn is_peer_validity_supported(peer_type: i32) -> bool { - let unsupported_peer_types = vec![ + let unsupported_peer_types = [ 4, // EVENTHUB 5, // S3 - 7, // EVENTHUBGROUP + 7, ]; !unsupported_peer_types.contains(&peer_type) }