[pre-commit.ci] auto fixes from pre-commit.com hooks

for more information, see https://pre-commit.ci

Author: pre-commit-ci[bot]

src/vdf_io/import_vdf/astradb_import.py

@@ -248,12 +248,15 @@ def flush_batch_to_db(collection, keys, vectors, metadata):
             for i in range(0, total_points, BATCH_SIZE)
         ]
 
-        with concurrent.futures.ThreadPoolExecutor(
-            max_workers=num_parallel_threads
-        ) as executor, tqdm(
-            total=total_points,
-            desc=f"Flushing to DB in batches of {BATCH_SIZE} in {num_parallel_threads} threads",
-        ) as pbar:
+        with (
+            concurrent.futures.ThreadPoolExecutor(
+                max_workers=num_parallel_threads
+            ) as executor,
+            tqdm(
+                total=total_points,
+                desc=f"Flushing to DB in batches of {BATCH_SIZE} in {num_parallel_threads} threads",
+            ) as pbar,
+        ):
             future_to_batch = {
                 executor.submit(flush_batch_to_db, collection, *batch): batch
                 for batch in batches

src/vdf_io/import_vdf/qdrant_import.py

@@ -313,12 +313,15 @@ def get_nested_config(config, keys, default=None):
                         total_points = len(points)
 
                         num_parallel_threads = self.args.get("parallel", 5) or 5
-                        with concurrent.futures.ThreadPoolExecutor(
-                            max_workers=num_parallel_threads
-                        ) as executor, tqdm(
-                            total=total_points,
-                            desc=f"Uploading points in batches of {BATCH_SIZE} in {num_parallel_threads} threads",
-                        ) as pbar:
+                        with (
+                            concurrent.futures.ThreadPoolExecutor(
+                                max_workers=num_parallel_threads
+                            ) as executor,
+                            tqdm(
+                                total=total_points,
+                                desc=f"Uploading points in batches of {BATCH_SIZE} in {num_parallel_threads} threads",
+                            ) as pbar,
+                        ):
                             # Create a future to batch mapping to update progress bar correctly after each batch completion
                             future_to_batch = {
                                 executor.submit(