backup/warcprox
1
0
Fork 0
mirror of https://github.com/internetarchive/warcprox.git synced 2025-01-18 13:22:09 +01:00
Code Issues Projects Releases Activity

fix idle rollover

Browse Source
This commit is contained in:
Noah Levitt 2019-01-21 10:37:09 -08:00
parent a780f1774c
commit cb72af015a
2 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
setup.py
View File

@ -41,7 +41,7 @@ except:
setuptools.setup( setuptools.setup(
name='warcprox', name='warcprox',
version='2.4b4.dev194', version='2.4b4.dev195',
description='WARC writing MITM HTTP/S proxy', description='WARC writing MITM HTTP/S proxy',
url='https://github.com/internetarchive/warcprox', url='https://github.com/internetarchive/warcprox',
author='Noah Levitt', author='Noah Levitt',

1
warcprox/writerthread.py
View File

@ -57,6 +57,7 @@ class WarcWriterProcessor(warcprox.BaseStandardPostfetchProcessor):
self.writer_pool.close_for_prefix(prefix) self.writer_pool.close_for_prefix(prefix)
except queue.Empty: except queue.Empty:
break break
self.writer_pool.maybe_idle_rollover()
super()._get_process_put() super()._get_process_put()
def close_for_prefix(self, prefix=None): def close_for_prefix(self, prefix=None):