Merge pull request #129 from phryneas/patch-1

wait until file is completely transmitted
This commit is contained in:
Daniel Quinn
2016-06-26 08:33:30 -07:00
committed by GitHub

View File

@@ -100,7 +100,7 @@ class Consumer(object):
if doc in self._ignore:
continue
if self._is_ready(doc):
if not self._is_ready(doc):
continue
if self._is_duplicate(doc):