summaryrefslogtreecommitdiffstats
path: root/python/fatcat_tools/workers
diff options
context:
space:
mode:
authorBryan Newbold <bnewbold@robocracy.org>2018-11-13 22:52:16 -0800
committerBryan Newbold <bnewbold@robocracy.org>2018-11-13 22:52:16 -0800
commit30d83fc99eac41f909f0907c9faad73897721eec (patch)
treebc7b6d4e2729be7110a8696b5e55e39fe7d6b7e3 /python/fatcat_tools/workers
parenta616256c6ff7d083fa7eebae6bc0ebaa1a9ac1aa (diff)
downloadfatcat-30d83fc99eac41f909f0907c9faad73897721eec.tar.gz
fatcat-30d83fc99eac41f909f0907c9faad73897721eec.zip
to_elastic_dict -> release_elastic_dict
Diffstat (limited to 'python/fatcat_tools/workers')
-rw-r--r--python/fatcat_tools/workers/elastic.py3
1 files changed, 2 insertions, 1 deletions
diff --git a/python/fatcat_tools/workers/elastic.py b/python/fatcat_tools/workers/elastic.py
index 22ec6fa6..119a6a26 100644
--- a/python/fatcat_tools/workers/elastic.py
+++ b/python/fatcat_tools/workers/elastic.py
@@ -2,6 +2,7 @@
import json
import time
import requests
+from fatcat_tools.transforms import release_elastic_dict
from fatcat_tools.workers.worker_common import FatcatWorker
from fatcat_client import ReleaseEntity
from fatcat_tools.transforms import *
@@ -42,6 +43,6 @@ class FatcatElasticReleaseWorker(FatcatWorker):
self.elastic_index,
release.ident)
print("Updating document: {}".format(elastic_endpoint))
- resp = requests.post(elastic_endpoint, json=release.to_elastic_dict())
+ resp = requests.post(elastic_endpoint, json=release_elastic_dict(release))
assert resp.status_code in (200, 201)
consumer.commit_offsets()