lint code

crates/core/src/context.rs

@@ -36,7 +36,7 @@ impl Context {
                 &datafusion::common::ScalarValue::Boolean(Some(false)),
             );
 
-        let _ = config.options_mut().extensions.insert(ext_config);
+        config.options_mut().extensions.insert(ext_config);
         config
     }
 

crates/core/src/datastream.rs

@@ -2,7 +2,6 @@ use datafusion::common::runtime::SpawnedTask;
 use datafusion::logical_expr::LogicalPlan;
 use datafusion::physical_plan::ExecutionPlanProperties;
 use futures::StreamExt;
-use log::debug;
 use log::info;
 use std::{sync::Arc, time::Duration};
 use tokio::signal;
@@ -229,7 +228,7 @@ impl DataStream {
     pub async fn print_physical_plan(self) -> Result<Self> {
         let (session_state, plan) = self.df.as_ref().clone().into_parts();
         let physical_plan = self.df.as_ref().clone().create_physical_plan().await?;
-        let node_id = physical_plan.node_id();
+        // let node_id = physical_plan.node_id();
         let displayable_plan = DisplayableExecutionPlan::new(physical_plan.as_ref());
 
         println!("{}", displayable_plan.indent(true));

crates/core/src/utils/serialization.rs

@@ -296,8 +296,7 @@ mod tests {
     };
     use arrow_schema::{Field, Fields};
     use datafusion::{
-        functions_aggregate::average::AvgAccumulator, logical_expr::Accumulator,
-        physical_expr::GroupsAccumulatorAdapter, scalar::ScalarValue,
+        functions_aggregate::average::AvgAccumulator, logical_expr::Accumulator, scalar::ScalarValue,
     };
     use std::sync::Arc;
 

py-denormalized/src/context.rs

@@ -54,7 +54,7 @@ impl PyContext {
     pub fn new(py: Python) -> PyResult<Self> {
         let rt = &get_tokio_runtime(py).0;
         let fut: JoinHandle<denormalized::common::error::Result<Context>> =
-            rt.spawn(async move { Ok(Context::new()?) });
+            rt.spawn(async move { Context::new() });
 
         let context = wait_for_future(py, fut).map_err(py_denormalized_err)??;