diff --git a/python/src/lib.rs b/python/src/lib.rs index 8a215039f3..1b38d0a127 100644 --- a/python/src/lib.rs +++ b/python/src/lib.rs @@ -306,7 +306,7 @@ impl RawDeltaTable { cmd = cmd.with_retention_period(Duration::hours(retention_period as i64)); } let (table, metrics) = rt()? - .block_on(async { cmd.await }) + .block_on(cmd.into_future()) .map_err(PyDeltaTableError::from_raw)?; self._table.state = table.state; Ok(metrics.files_deleted) @@ -328,7 +328,7 @@ impl RawDeltaTable { cmd = cmd.with_filters(&converted_filters); let (table, metrics) = rt()? - .block_on(async { cmd.await }) + .block_on(cmd.into_future()) .map_err(PyDeltaTableError::from_raw)?; self._table.state = table.state; Ok(serde_json::to_string(&metrics).unwrap())