revert to prepend/append division values

mrocklin · Jan 31, 2018 · 6349123 · 6349123
1 parent c7d53a3
commit 6349123
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/dask/dataframe/core.py b/dask/dataframe/core.py
@@ -3810,8 +3810,10 @@ def repartition_freq(df, freq=None):
     if not len(divisions):
         divisions = [df.divisions[0], df.divisions[-1]]
     else:
-        divisions[0] = df.divisions[0]
-        divisions[-1] = df.divisions[-1]
+        if divisions[-1] != df.divisions[-1]:
+            divisions.append(df.divisions[-1])
+        if divisions[0] != df.divisions[0]:
+            divisions = [df.divisions[0]] + divisions
 
     return df.repartition(divisions=divisions)