diff options
| author | Bryan Newbold <bnewbold@robocracy.org> | 2018-11-13 22:52:16 -0800 |
|---|---|---|
| committer | Bryan Newbold <bnewbold@robocracy.org> | 2018-11-13 22:52:16 -0800 |
| commit | 30d83fc99eac41f909f0907c9faad73897721eec (patch) | |
| tree | bc7b6d4e2729be7110a8696b5e55e39fe7d6b7e3 | |
| parent | a616256c6ff7d083fa7eebae6bc0ebaa1a9ac1aa (diff) | |
| download | fatcat-30d83fc99eac41f909f0907c9faad73897721eec.tar.gz fatcat-30d83fc99eac41f909f0907c9faad73897721eec.zip | |
to_elastic_dict -> release_elastic_dict
| -rw-r--r-- | python/fatcat_tools/workers/elastic.py | 3 |
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() |