diff --git a/dozer-api/src/grpc/client_server.rs b/dozer-api/src/grpc/client_server.rs
index 66ab37aa5b..5cf666e3a4 100644
--- a/dozer-api/src/grpc/client_server.rs
+++ b/dozer-api/src/grpc/client_server.rs
@@ -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());
diff --git a/dozer-ingestion/src/connectors/object_store/connector.rs b/dozer-ingestion/src/connectors/object_store/connector.rs
index 9c481a93ec..557e5cbfc1 100644
--- a/dozer-ingestion/src/connectors/object_store/connector.rs
+++ b/dozer-ingestion/src/connectors/object_store/connector.rs
@@ -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>(())
                                 });
diff --git a/dozer-ingestion/src/connectors/snowflake/connection/client.rs b/dozer-ingestion/src/connectors/snowflake/connection/client.rs
index 6c0dc0acf6..f3e72805c5 100644
--- a/dozer-ingestion/src/connectors/snowflake/connection/client.rs
+++ b/dozer-ingestion/src/connectors/snowflake/connection/client.rs
@@ -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