diff --git a/piker/tsp/_history.py b/piker/tsp/_history.py
index d416c679..e875bab7 100644
--- a/piker/tsp/_history.py
+++ b/piker/tsp/_history.py
@@ -708,8 +708,16 @@ async def start_backfill(
                     deduped,
                     diff,
                 ) = dedupe(df)
-                # if diff:
-                #     sort_diff(df)
+                if diff:
+                    log.warning(
+                        f'Found {diff} duplicates in tsdb, '
+                        f'overwriting with deduped data\n'
+                    )
+                    await storage.write_ohlcv(
+                        col_sym_key,
+                        deduped,
+                        timeframe,
+                    )
 
         else:
             # finally filled gap