removing nparttions

coiled · Jun 25, 2024 · 3e067d4 · 3e067d4
1 parent cb50d0c
commit 3e067d4
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/dask_snowflake/core.py b/dask_snowflake/core.py
@@ -314,12 +314,12 @@ def read_snowflake(
         batches, meta, npartitions=npartitions, partition_size=partition_size
     )
 
-    divisions = tuple([None] * (len(batches_partitioned) + 1))
+    # divisions = tuple([None] * (len(batches_partitioned) + 1))
 
     return dd.from_map(
         partial(_fetch_batches, arrow_options=arrow_options),
         batches_partitioned,
-        npartitions=divisions,
+        # npartitions=divisions,
         meta=meta,
     )