@@ -40,7 +40,10 @@ def test_multiple_cursors(self, duckdb_cursor):
4040
4141 # Kick off multiple threads (in the same process)
4242 # Pass in the same connection as an argument, and an object to store the results
43- threads = [Thread (target = insert_from_cursor , args = (duckdb_con ,), name = "my_thread_" + str (i )) for i in range (thread_count )]
43+ threads = [
44+ Thread (target = insert_from_cursor , args = (duckdb_con ,), name = "my_thread_" + str (i ))
45+ for i in range (thread_count )
46+ ]
4447
4548 for thread in threads :
4649 thread .start ()
@@ -88,7 +91,10 @@ def test_multiple_cursors_persisted(self, tmp_database):
8891
8992 # Kick off multiple threads (in the same process)
9093 # Pass in the same connection as an argument, and an object to store the results
91- threads = [Thread (target = insert_from_cursor , args = (duckdb_con ,), name = "my_thread_" + str (i )) for i in range (thread_count )]
94+ threads = [
95+ Thread (target = insert_from_cursor , args = (duckdb_con ,), name = "my_thread_" + str (i ))
96+ for i in range (thread_count )
97+ ]
9298
9399 for thread in threads :
94100 thread .start ()
@@ -111,7 +117,10 @@ def test_same_connection_persisted(self, tmp_database):
111117
112118 # Kick off multiple threads (in the same process)
113119 # Pass in the same connection as an argument, and an object to store the results
114- threads = [Thread (target = insert_from_same_connection , args = (duckdb_con ,), name = "my_thread_" + str (i )) for i in range (thread_count )]
120+ threads = [
121+ Thread (target = insert_from_same_connection , args = (duckdb_con ,), name = "my_thread_" + str (i ))
122+ for i in range (thread_count )
123+ ]
115124 for thread in threads :
116125 thread .start ()
117126
0 commit comments