diff options
| author | Bryan Newbold <bnewbold@robocracy.org> | 2018-11-14 23:23:07 -0800 |
|---|---|---|
| committer | Bryan Newbold <bnewbold@robocracy.org> | 2018-11-14 23:23:07 -0800 |
| commit | ef50d665b31a8cb1b0ddc38671b3334b0fa6fc14 (patch) | |
| tree | ea7d4fc799746df9b6afa6715ecc155ca054d796 /python/fatcat_tools/workers/worker_common.py | |
| parent | a1b63a58410f01f93027f25e8041d0aed6317bbc (diff) | |
| download | fatcat-ef50d665b31a8cb1b0ddc38671b3334b0fa6fc14.tar.gz fatcat-ef50d665b31a8cb1b0ddc38671b3334b0fa6fc14.zip | |
fix worker code
Diffstat (limited to 'python/fatcat_tools/workers/worker_common.py')
| -rw-r--r-- | python/fatcat_tools/workers/worker_common.py | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/python/fatcat_tools/workers/worker_common.py b/python/fatcat_tools/workers/worker_common.py index 66150644..daae91b3 100644 --- a/python/fatcat_tools/workers/worker_common.py +++ b/python/fatcat_tools/workers/worker_common.py @@ -5,7 +5,9 @@ import csv import json import itertools import fatcat_client +from itertools import islice from pykafka import KafkaClient +from pykafka.common import OffsetType from fatcat_client.rest import ApiException |