From ef50d665b31a8cb1b0ddc38671b3334b0fa6fc14 Mon Sep 17 00:00:00 2001 From: Bryan Newbold Date: Wed, 14 Nov 2018 23:23:07 -0800 Subject: fix worker code --- python/fatcat_tools/workers/worker_common.py | 2 ++ 1 file changed, 2 insertions(+) (limited to 'python/fatcat_tools/workers/worker_common.py') 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 -- cgit v1.2.3