diff options
| -rw-r--r-- | python/sandcrawler/workers.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/python/sandcrawler/workers.py b/python/sandcrawler/workers.py index cb38146..9f7c913 100644 --- a/python/sandcrawler/workers.py +++ b/python/sandcrawler/workers.py @@ -149,7 +149,7 @@ class KafkaSink(SandcrawlerWorker): on_delivery=self._fail_fast) self.counts['produced'] += 1 - # TODO: check for errors etc. is this necessary? + # check for errors etc self.producer.poll(0) def push_batch(self, msgs): |