aboutsummaryrefslogtreecommitdiffstats
path: root/python/fatcat_tools/workers
diff options
context:
space:
mode:
authorBryan Newbold <bnewbold@robocracy.org>2021-11-02 15:24:40 -0700
committerBryan Newbold <bnewbold@robocracy.org>2021-11-02 17:02:50 -0700
commit675ecb96fe0e51f169c2d01683f02205ef327825 (patch)
tree19be01afe2ddb0791368a1b9b5223deb3cba6d19 /python/fatcat_tools/workers
parente148fce040b874c7dd397cb22118a3c03b7f02d4 (diff)
downloadfatcat-675ecb96fe0e51f169c2d01683f02205ef327825.tar.gz
fatcat-675ecb96fe0e51f169c2d01683f02205ef327825.zip
cleanup imports after fatcat_tools.transforms change
Diffstat (limited to 'python/fatcat_tools/workers')
-rw-r--r--python/fatcat_tools/workers/elasticsearch.py13
1 files changed, 8 insertions, 5 deletions
diff --git a/python/fatcat_tools/workers/elasticsearch.py b/python/fatcat_tools/workers/elasticsearch.py
index b8735a37..91f2796c 100644
--- a/python/fatcat_tools/workers/elasticsearch.py
+++ b/python/fatcat_tools/workers/elasticsearch.py
@@ -1,17 +1,20 @@
-import sys
import json
+import sys
-import requests
import elasticsearch
+import requests
from confluent_kafka import Consumer, KafkaException
+from fatcat_openapi_client import ApiClient, ChangelogEntry, ContainerEntity, ReleaseEntity
-from fatcat_openapi_client import ReleaseEntity, ContainerEntity, ApiClient, ChangelogEntry
-from fatcat_tools import (public_api, entity_from_json,
- release_to_elasticsearch, container_to_elasticsearch,
+from fatcat_tools import entity_from_json, public_api
+from fatcat_tools.transforms import (
changelog_to_elasticsearch,
+ container_to_elasticsearch,
+ release_to_elasticsearch,
)
from fatcat_web.search import get_elastic_container_stats
+
from .worker_common import FatcatWorker