@@ -24,11 +24,10 @@ def pl_scan_pq(
2424 row_count_offset : int = 0 ,
2525 parallel : ParallelStrategy = "auto" ,
2626 use_statistics : bool = True ,
27- hive_partitioning : bool = True ,
2827 rechunk : bool = True ,
2928 low_memory : bool = False ,
3029 cache : bool = True ,
31- storage_options = stor ,
30+ storage_options = None ,
3231 retries : int = 0 ,
3332) -> pl .LazyFrame :
3433 """
@@ -61,6 +60,8 @@ def pl_scan_pq(
6160 Cache the result after reading.
6261 retries
6362 Number of retries if accessing a cloud instance fails."""
63+ if storage_options is None :
64+ storage_options = stor
6465 return pl .scan_parquet (
6566 f"abfs://{ source } " ,
6667 n_rows = n_rows ,
@@ -85,11 +86,10 @@ def pl_scan_hive(
8586 row_count_offset : int = 0 ,
8687 parallel : ParallelStrategy = "auto" ,
8788 use_statistics : bool = True ,
88- hive_partitioning : bool = True ,
8989 rechunk : bool = True ,
9090 low_memory : bool = False ,
9191 cache : bool = True ,
92- storage_options = stor ,
92+ storage_options = None ,
9393 retries : int = 0 ,
9494) -> pl .LazyFrame :
9595 """
@@ -122,6 +122,8 @@ def pl_scan_hive(
122122 Cache the result after reading.
123123 retries
124124 Number of retries if accessing a cloud instance fails."""
125+ if storage_options is None :
126+ storage_options = stor
125127 return pl .scan_parquet (
126128 f"abfs://{ source } " ,
127129 n_rows = n_rows ,
0 commit comments