Skip to content

Commit b3ec22b

Browse files
cpsievertclaude
andcommitted
style: format Rust code
Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>
1 parent 16ef14b commit b3ec22b

1 file changed

Lines changed: 18 additions & 4 deletions

File tree

ggsql-python/src/lib.rs

Lines changed: 18 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -355,7 +355,12 @@ impl PyDuckDBReader {
355355
/// >>> writer = VegaLiteWriter()
356356
/// >>> json_output = writer.render(spec)
357357
#[pyo3(signature = (query, *, data=None))]
358-
fn execute(&self, py: Python<'_>, query: &str, data: Option<&Bound<'_, PyDict>>) -> PyResult<PySpec> {
358+
fn execute(
359+
&self,
360+
py: Python<'_>,
361+
query: &str,
362+
data: Option<&Bound<'_, PyDict>>,
363+
) -> PyResult<PySpec> {
359364
// Register DataFrames from data dict
360365
let registered_names = if let Some(data_dict) = data {
361366
self.register_data_dict(py, data_dict)?
@@ -364,7 +369,8 @@ impl PyDuckDBReader {
364369
};
365370

366371
// Execute query (capture result, don't return early)
367-
let result = self.inner
372+
let result = self
373+
.inner
368374
.execute(query)
369375
.map(|s| PySpec { inner: s })
370376
.map_err(ggsql_err_to_py);
@@ -804,7 +810,12 @@ fn validate(query: &str) -> PyResult<PyValidated> {
804810
/// >>> spec = execute("SELECT * FROM data VISUALISE x, y DRAW point", reader)
805811
#[pyfunction]
806812
#[pyo3(signature = (query, reader, *, data=None))]
807-
fn execute(py: Python<'_>, query: &str, reader: &Bound<'_, PyAny>, data: Option<&Bound<'_, PyDict>>) -> PyResult<PySpec> {
813+
fn execute(
814+
py: Python<'_>,
815+
query: &str,
816+
reader: &Bound<'_, PyAny>,
817+
data: Option<&Bound<'_, PyDict>>,
818+
) -> PyResult<PySpec> {
808819
// Native reader fast path: DuckDBReader
809820
// Note: we can't use the try_native_readers! macro here because it uses `return`
810821
// which would skip cleanup of registered tables.
@@ -817,7 +828,10 @@ fn execute(py: Python<'_>, query: &str, reader: &Bound<'_, PyAny>, data: Option<
817828
};
818829

819830
// Execute (capture result for cleanup)
820-
let result = native.borrow().inner.execute(query)
831+
let result = native
832+
.borrow()
833+
.inner
834+
.execute(query)
821835
.map(|s| PySpec { inner: s })
822836
.map_err(ggsql_err_to_py);
823837

0 commit comments

Comments
 (0)