make use of read_csv options

semio · Jul 8, 2020 · 2c29497 · 2c29497
1 parent 83b18e5
commit 2c29497
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/ddf_utils/model/ddf.py b/ddf_utils/model/ddf.py
@@ -218,7 +218,7 @@ class DaskDataPoint(DataPoint):
     @property
     def data(self):
         cols = [*self.dimensions, self.id]
-        df = dd.read_csv(self.path, **self.read_csv_options)[cols]
+        df = dd.read_csv(self.path, usecols=cols, **self.read_csv_options)
         # handling time columns
         for k, v in self.concept_types.items():
             if v == 'time':