wassname/catalyst
1
0 Fork 0
mirror of https://github.com/wassname/catalyst.git synced 2026-10-30 13:10:53 +08:00
Code Issues Packages Projects Releases Wiki Activity

Fixed an issue with writer retry

Browse Source
This commit is contained in:
fredfortier committed 2017-10-18 00:18:07 -04:00
1 parent 74fd4a6a0f
commit 733f2c3433
1 file changed
+4 -1
Download Patch File Download Diff File Expand all files Collapse all files
catalyst/exchange/exchange_bundle.py
+4 -1
View File
@@ -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)