@@ -133,11 +133,14 @@ def test_commit(tmp_path):
133133 cur .adbc_ingest ("ingest" , table , "create" )
134134
135135 # This now works because we enabled autocommit
136- with adbc_driver_manager .connect (
137- driver = driver_path ,
138- entrypoint = "duckdb_adbc_init" ,
139- db_kwargs = db_kwargs ,
140- ) as conn , conn .cursor () as cur :
136+ with (
137+ adbc_driver_manager .connect (
138+ driver = driver_path ,
139+ entrypoint = "duckdb_adbc_init" ,
140+ db_kwargs = db_kwargs ,
141+ ) as conn ,
142+ conn .cursor () as cur ,
143+ ):
141144 cur .execute ("SELECT count(*) from ingest" )
142145 assert cur .fetch_arrow_table ().to_pydict () == {"count_star()" : [4 ]}
143146
@@ -302,12 +305,15 @@ def test_large_chunk(tmp_path):
302305 if os .path .exists (db ):
303306 os .remove (db )
304307 db_kwargs = {"path" : f"{ db } " }
305- with adbc_driver_manager .connect (
306- driver = driver_path ,
307- entrypoint = "duckdb_adbc_init" ,
308- db_kwargs = db_kwargs ,
309- autocommit = True ,
310- ) as conn , conn .cursor () as cur :
308+ with (
309+ adbc_driver_manager .connect (
310+ driver = driver_path ,
311+ entrypoint = "duckdb_adbc_init" ,
312+ db_kwargs = db_kwargs ,
313+ autocommit = True ,
314+ ) as conn ,
315+ conn .cursor () as cur ,
316+ ):
311317 cur .adbc_ingest ("ingest" , table , "create" )
312318 cur .execute ("SELECT count(*) from ingest" )
313319 assert cur .fetch_arrow_table ().to_pydict () == {"count_star()" : [30_000 ]}
@@ -325,12 +331,15 @@ def test_dictionary_data(tmp_path):
325331 if os .path .exists (db ):
326332 os .remove (db )
327333 db_kwargs = {"path" : f"{ db } " }
328- with adbc_driver_manager .connect (
329- driver = driver_path ,
330- entrypoint = "duckdb_adbc_init" ,
331- db_kwargs = db_kwargs ,
332- autocommit = True ,
333- ) as conn , conn .cursor () as cur :
334+ with (
335+ adbc_driver_manager .connect (
336+ driver = driver_path ,
337+ entrypoint = "duckdb_adbc_init" ,
338+ db_kwargs = db_kwargs ,
339+ autocommit = True ,
340+ ) as conn ,
341+ conn .cursor () as cur ,
342+ ):
334343 cur .adbc_ingest ("ingest" , table , "create" )
335344 cur .execute ("from ingest" )
336345 assert cur .fetch_arrow_table ().to_pydict () == {
@@ -350,12 +359,15 @@ def test_ree_data(tmp_path):
350359 if os .path .exists (db ):
351360 os .remove (db )
352361 db_kwargs = {"path" : f"{ db } " }
353- with adbc_driver_manager .connect (
354- driver = driver_path ,
355- entrypoint = "duckdb_adbc_init" ,
356- db_kwargs = db_kwargs ,
357- autocommit = True ,
358- ) as conn , conn .cursor () as cur :
362+ with (
363+ adbc_driver_manager .connect (
364+ driver = driver_path ,
365+ entrypoint = "duckdb_adbc_init" ,
366+ db_kwargs = db_kwargs ,
367+ autocommit = True ,
368+ ) as conn ,
369+ conn .cursor () as cur ,
370+ ):
359371 cur .adbc_ingest ("ingest" , table , "create" )
360372 cur .execute ("from ingest" )
361373 assert cur .fetch_arrow_table ().to_pydict () == {
0 commit comments