summaryrefslogtreecommitdiffstats
path: root/python/fatcat_tools/workers/worker_common.py
diff options
context:
space:
mode:
authorBryan Newbold <bnewbold@robocracy.org>2018-11-14 23:23:07 -0800
committerBryan Newbold <bnewbold@robocracy.org>2018-11-14 23:23:07 -0800
commitef50d665b31a8cb1b0ddc38671b3334b0fa6fc14 (patch)
treeea7d4fc799746df9b6afa6715ecc155ca054d796 /python/fatcat_tools/workers/worker_common.py
parenta1b63a58410f01f93027f25e8041d0aed6317bbc (diff)
downloadfatcat-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.py2
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