Skip to content

Commit

Permalink
chore: Remove redundant variable assign (#2127)
Browse files Browse the repository at this point in the history
* chore: Remove redundant variable assign

* fix other clippy warnings
  • Loading branch information
karolisg authored Oct 6, 2023
1 parent e01363b commit d53a131
Show file tree
Hide file tree
Showing 3 changed files with 2 additions and 4 deletions.
1 change: 0 additions & 1 deletion dozer-api/src/grpc/client_server.rs
Original file line number Diff line number Diff line change
Expand Up @@ -143,7 +143,6 @@ impl ApiServer {
} else {
unauthenticated_reflection_service = Some(reflection_service);
};
let health_service = health_service;

let mut auth_service = None;
let security = get_api_security(self.security.to_owned());
Expand Down
1 change: 0 additions & 1 deletion dozer-ingestion/src/connectors/object_store/connector.rs
Original file line number Diff line number Diff line change
Expand Up @@ -210,7 +210,6 @@ impl<T: DozerObjectStore> Connector for ObjectStoreConnector<T> {
joinset.spawn(async move {
let mut csv_table = CsvTable::new(csv_config, config);
csv_table.update_state = state;
let table_info = table_info;
csv_table.watch(table_index, &table_info, sender).await?;
Ok::<_, ConnectorError>(())
});
Expand Down
4 changes: 2 additions & 2 deletions dozer-ingestion/src/connectors/snowflake/connection/client.rs
Original file line number Diff line number Diff line change
Expand Up @@ -351,13 +351,13 @@ impl<'env> Client<'env> {
.map(|(name, (_, schema))| match schema {
Ok(mut schema) => {
let mut indexes = vec![];
keys.get(&name).map_or((), |columns| {
if let Some(columns) = keys.get(&name) {
schema.fields.iter().enumerate().for_each(|(idx, f)| {
if columns.contains(&f.name) {
indexes.push(idx);
}
});
});
}

let cdc_type = if indexes.is_empty() {
CdcType::Nothing
Expand Down

0 comments on commit d53a131

Please sign in to comment.