From 733f2c3433217c1ce42a692522dcff69b306fd4c Mon Sep 17 00:00:00 2001 From: fredfortier Date: Wed, 18 Oct 2017 00:18:07 -0400 Subject: [PATCH] Fixed an issue with writer retry --- catalyst/exchange/exchange_bundle.py | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) 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)