This is an automated email from the ASF dual-hosted git repository. yuxia pushed a commit to branch support-database-level-ops in repository https://gitbox.apache.org/repos/asf/fluss-rust.git
commit 392830d62fa0cd341d9302d0f2b5c91a532172d0 Author: luoyuxia <[email protected]> AuthorDate: Sun Feb 8 12:15:52 2026 +0800 chore: fix ci --- bindings/cpp/src/types.rs | 2 +- bindings/python/src/admin.rs | 13 +++++-------- bindings/python/src/metadata.rs | 2 +- bindings/python/src/table.rs | 6 +++--- 4 files changed, 10 insertions(+), 13 deletions(-) diff --git a/bindings/cpp/src/types.rs b/bindings/cpp/src/types.rs index 7837032..05d3d6a 100644 --- a/bindings/cpp/src/types.rs +++ b/bindings/cpp/src/types.rs @@ -257,7 +257,7 @@ fn get_decimal_type(idx: usize, schema: Option<&fcore::metadata::Schema>) -> Res .ok_or_else(|| anyhow!("Schema not available for decimal column {idx}"))?; match col.data_type() { fcore::metadata::DataType::Decimal(dt) => Ok((dt.precision(), dt.scale())), - other => Err(anyhow!("Column {idx} is {:?}, not Decimal", other)), + other => Err(anyhow!("Column {idx} is {other:?}, not Decimal")), } } diff --git a/bindings/python/src/admin.rs b/bindings/python/src/admin.rs index d5b4ddb..8abf761 100644 --- a/bindings/python/src/admin.rs +++ b/bindings/python/src/admin.rs @@ -38,8 +38,7 @@ fn parse_offset_spec(offset_type: &str, timestamp: Option<i64>) -> PyResult<Offs Ok(OffsetSpec::Timestamp(ts)) } _ => Err(FlussError::new_err(format!( - "Invalid offset_type: '{}'. Must be 'earliest', 'latest', or 'timestamp'", - offset_type + "Invalid offset_type: '{offset_type}'. Must be 'earliest', 'latest', or 'timestamp'" ))), } } @@ -49,8 +48,7 @@ fn validate_bucket_ids(bucket_ids: &[i32]) -> PyResult<()> { for &bucket_id in bucket_ids { if bucket_id < 0 { return Err(FlussError::new_err(format!( - "Invalid bucket_id: {}. Bucket IDs must be non-negative", - bucket_id + "Invalid bucket_id: {bucket_id}. Bucket IDs must be non-negative" ))); } } @@ -159,10 +157,9 @@ impl FlussAdmin { let name = database_name.to_string(); future_into_py(py, async move { - let exists = admin - .database_exists(&name) - .await - .map_err(|e| FlussError::new_err(format!("Failed to check database exists: {e}")))?; + let exists = admin.database_exists(&name).await.map_err(|e| { + FlussError::new_err(format!("Failed to check database exists: {e}")) + })?; Python::attach(|py| { let builtins = py.import("builtins")?; diff --git a/bindings/python/src/metadata.rs b/bindings/python/src/metadata.rs index 93cbebf..d6b122d 100644 --- a/bindings/python/src/metadata.rs +++ b/bindings/python/src/metadata.rs @@ -53,7 +53,7 @@ impl ChangeType { } fn __repr__(&self) -> String { - format!("ChangeType.{:?}", self) + format!("ChangeType.{self:?}") } } diff --git a/bindings/python/src/table.rs b/bindings/python/src/table.rs index d926596..cb203dc 100644 --- a/bindings/python/src/table.rs +++ b/bindings/python/src/table.rs @@ -315,7 +315,7 @@ fn resolve_projection_indices( let idx = columns .iter() .position(|c| c.name() == name) - .ok_or_else(|| FlussError::new_err(format!("Column '{}' not found", name)))?; + .ok_or_else(|| FlussError::new_err(format!("Column '{name}' not found")))?; indices.push(idx); } Ok(Some(indices)) @@ -796,9 +796,9 @@ pub fn python_pk_to_generic_row( let field: &fcore::metadata::DataField = &fields[*pk_idx]; let value = dict .get_item(pk_name)? - .ok_or_else(|| FlussError::new_err(format!("Missing PK field: {}", pk_name)))?; + .ok_or_else(|| FlussError::new_err(format!("Missing PK field: {pk_name}")))?; datums[*pk_idx] = python_value_to_datum(&value, field.data_type()) - .map_err(|e| FlussError::new_err(format!("PK field '{}': {}", pk_name, e)))?; + .map_err(|e| FlussError::new_err(format!("PK field '{pk_name}': {e}")))?; } }
