use tokio mutex

Cargo.toml

@@ -31,6 +31,7 @@ url = "^2.2"
 uuid = { version = "1.3.2", features = ["serde", "v4"] }
 itertools = "0.10.5"
 derive-getters = "0.3.0"
+tokio = { version = "1.0", features = ["sync"] }
 tracing = "0.1"
 tracing-futures = "0.2"
 

datafusion_iceberg/Cargo.toml

@@ -23,7 +23,7 @@ itertools = { workspace = true }
 dashmap = "5.4.0"
 uuid = { workspace = true }
 thiserror = { workspace = true }
-tokio = { version = "1.0", features = ["sync","rt-multi-thread"] }
+tokio = { workspace = true }
 
 [dev-dependencies]
 tokio = "1"

iceberg-sql-catalog/Cargo.toml

@@ -20,6 +20,7 @@ sqlx = { version = "0.7.4", features = ["tls-rustls", "any", "sqlite", "postgres
 thiserror.workspace = true
 url.workspace = true
 uuid = { version = "1.7.0", features = ["v4"] }
+tokio = { workspace = true }
 
 [dev-dependencies]
 tokio = "1"

iceberg-sql-catalog/src/lib.rs

@@ -2,7 +2,6 @@ use std::{collections::HashMap, sync::Arc};
 
 use async_trait::async_trait;
 use dashmap::DashMap;
-use futures::lock::Mutex;
 use iceberg_rust::{
     catalog::{
         bucket::Bucket,
@@ -33,6 +32,7 @@ use sqlx::{
     any::{install_default_drivers, AnyRow},
     AnyConnection, Connection, Row,
 };
+use tokio::sync::Mutex;
 use uuid::Uuid;
 
 use crate::error::Error;