diff --git a/lib/chrontext/src/sparql_database/sparql_embedded_oxigraph.rs b/lib/chrontext/src/sparql_database/sparql_embedded_oxigraph.rs index 4817db2..26e9bc9 100644 --- a/lib/chrontext/src/sparql_database/sparql_embedded_oxigraph.rs +++ b/lib/chrontext/src/sparql_database/sparql_embedded_oxigraph.rs @@ -108,8 +108,10 @@ impl EmbeddedOxigraph { let mut reader = BufReader::new(file); store .bulk_loader() - .load_from_read(RdfParser::from_format(RdfFormat::NQuads).unchecked(), - &mut reader) + .load_from_read( + RdfParser::from_format(RdfFormat::NQuads).unchecked(), + &mut reader, + ) .map_err(|x| EmbeddedOxigraphError::LoaderError(x.to_string()))?; if let Some(p) = &config.path { let mut pb = Path::new(p).to_path_buf(); diff --git a/lib/chrontext/src/sparql_database/sparql_endpoint.rs b/lib/chrontext/src/sparql_database/sparql_endpoint.rs index 3360b5e..e0715b3 100644 --- a/lib/chrontext/src/sparql_database/sparql_endpoint.rs +++ b/lib/chrontext/src/sparql_database/sparql_endpoint.rs @@ -2,7 +2,10 @@ use super::SparqlQueryable; use async_trait::async_trait; use reqwest::header::{ACCEPT, USER_AGENT}; use reqwest::StatusCode; -use sparesults::{FromReadQueryResultsReader, QueryResultsFormat, QueryResultsParseError, QueryResultsParser, QuerySolution}; +use sparesults::{ + FromReadQueryResultsReader, QueryResultsFormat, QueryResultsParseError, QueryResultsParser, + QuerySolution, +}; use spargebra::Query; use std::error::Error; use std::fmt::{Display, Formatter}; diff --git a/py_chrontext/src/lib.rs b/py_chrontext/src/lib.rs index de5d7c3..30117b0 100644 --- a/py_chrontext/src/lib.rs +++ b/py_chrontext/src/lib.rs @@ -151,7 +151,12 @@ impl Engine { Ok(()) } - pub fn query(&mut self, py: Python<'_>, sparql: &str, multi_to_strings: Option) -> PyResult { + pub fn query( + &mut self, + py: Python<'_>, + sparql: &str, + multi_to_strings: Option, + ) -> PyResult { if self.engine.is_none() { self.init()?; } @@ -164,7 +169,8 @@ impl Engine { .block_on(self.engine.as_mut().unwrap().execute_hybrid_query(sparql)) .map_err(|err| PyChrontextError::QueryExecutionError(err))?; - (df, datatypes) = fix_cats_and_multicolumns(df, datatypes, multi_to_strings.unwrap_or(false)); + (df, datatypes) = + fix_cats_and_multicolumns(df, datatypes, multi_to_strings.unwrap_or(false)); let pydf = df_to_py_df(df, dtypes_map(datatypes), py)?; Ok(pydf) } @@ -177,7 +183,7 @@ impl Engine { builder.enable_all(); let config = Config::default(); let catalog = catalog.to_rust()?; - let res = builder + builder .build() .unwrap() .block_on(start_server(self.engine.take().unwrap(), config, catalog))