diff --git a/freqtrade/data/datahandlers/jsondatahandler.py b/freqtrade/data/datahandlers/jsondatahandler.py
index 7d780a48d..e76fee2b9 100644
--- a/freqtrade/data/datahandlers/jsondatahandler.py
+++ b/freqtrade/data/datahandlers/jsondatahandler.py
@@ -74,6 +74,19 @@ class JsonDataHandler(IDataHandler):
                                        infer_datetime_format=True)
         return pairdata
 
+    def ohlcv_purge(self, pair: str, timeframe: str) -> bool:
+        """
+        Remove data for this pair
+        :param pair: Delete data for this pair.
+        :param timeframe: Ticker timeframe (e.g. "5m")
+        :return: True when deleted, false if file did not exist.
+        """
+        filename = self._pair_data_filename(self._datadir, pair, timeframe)
+        if filename.is_file():
+            filename.unlink()
+            return True
+        return False
+
     def ohlcv_append(self, pair: str, timeframe: str, data: DataFrame) -> None:
         """
         Append data to existing data structures
diff --git a/freqtrade/data/history.py b/freqtrade/data/history.py
index e71d9f36c..9347e7ee5 100644
--- a/freqtrade/data/history.py
+++ b/freqtrade/data/history.py
@@ -374,7 +374,7 @@ def refresh_backtest_trades_data(exchange: Exchange, pairs: List[str], datadir:
                 logger.info(f'Deleting existing data for pair {pair}.')
 
         logger.info(f'Downloading trades for pair {pair}.')
-        _download_trades_history(datadir=datadir, exchange=exchange,
+        _download_trades_history(exchange=exchange,
                                  pair=pair,
                                  timerange=timerange,
                                  data_handler=data_handler)
@@ -392,10 +392,9 @@ def convert_trades_to_ohlcv(pairs: List[str], timeframes: List[str],
     for pair in pairs:
         trades = data_handler_trades.trades_load(pair)
         for timeframe in timeframes:
-            ohlcv_file = pair_data_filename(datadir, pair, timeframe)
-            if erase and ohlcv_file.exists():
-                logger.info(f'Deleting existing data for pair {pair}, interval {timeframe}.')
-                ohlcv_file.unlink()
+            if erase:
+                if data_handler_ohlcv.ohlcv_purge(pair, timeframe):
+                    logger.info(f'Deleting existing data for pair {pair}, interval {timeframe}.')
             ohlcv = trades_to_ohlcv(trades, timeframe)
             # Store ohlcv
             data_handler_ohlcv.ohlcv_store(pair, timeframe, data=ohlcv)