diff --git a/setup.py b/setup.py index 80b70d2..ceb9886 100755 --- a/setup.py +++ b/setup.py @@ -41,7 +41,7 @@ except: setuptools.setup( name='warcprox', - version='2.4b4.dev194', + version='2.4b4.dev195', description='WARC writing MITM HTTP/S proxy', url='https://github.com/internetarchive/warcprox', author='Noah Levitt', diff --git a/warcprox/writerthread.py b/warcprox/writerthread.py index f6ac277..b929a7f 100644 --- a/warcprox/writerthread.py +++ b/warcprox/writerthread.py @@ -57,6 +57,7 @@ class WarcWriterProcessor(warcprox.BaseStandardPostfetchProcessor): self.writer_pool.close_for_prefix(prefix) except queue.Empty: break + self.writer_pool.maybe_idle_rollover() super()._get_process_put() def close_for_prefix(self, prefix=None):