Skip to content

Commit

Permalink
fix more lints
Browse files Browse the repository at this point in the history
  • Loading branch information
iskakaushik committed Oct 5, 2023
1 parent 0951fbd commit cccf277
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 3 deletions.
2 changes: 1 addition & 1 deletion nexus/peer-cursor/src/util.rs
Original file line number Diff line number Diff line change
Expand Up @@ -88,7 +88,7 @@ pub fn records_to_query_response<'a>(records: Records) -> PgWireResult<Response<
let pg_schema: Arc<Vec<FieldInfo>> = 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() {
Expand Down
4 changes: 2 additions & 2 deletions nexus/server/src/main.rs
Original file line number Diff line number Diff line change
Expand Up @@ -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)
}
Expand Down

0 comments on commit cccf277

Please sign in to comment.