diff --git a/catalyst/exchange/exchange_bundle.py b/catalyst/exchange/exchange_bundle.py index 6198cdc3..060cf776 100644 --- a/catalyst/exchange/exchange_bundle.py +++ b/catalyst/exchange/exchange_bundle.py @@ -207,7 +207,10 @@ class ExchangeBundle: # This is workaround, there is an issue with empty # session_label when using a newly created writer - del self._writers[writer._rootdir] + key = writer._rootdir if data_frequency == 'minute' \ + else writer._filename + + del self._writers[key] writer = self.get_writer(writer._start_session, writer._end_session, data_frequency)