Pass storage options to dask too

intake · Jun 18, 2018 · 817ed57 · 817ed57
1 parent cd17af1
commit 817ed57
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/intake_parquet/source.py b/intake_parquet/source.py
@@ -119,10 +119,12 @@ def to_dask(self):
         index = self._kwargs.get('index', None)
         filters = self._kwargs.get('filters', [])
         self._df = dd.read_parquet(self._urlpath, columns=columns, index=index,
-                                   filters=filters)
+                                   filters=filters,
+                                   storage_options=self._storage_options)
         self._schema = None
         self.discover()  # resets schema to dask's better version
         return self._df
 
     def _close(self):
         self._pf = None
+        self._df = None