diff options
| author | Bryan Newbold <bnewbold@archive.org> | 2021-01-25 17:13:14 -0800 |
|---|---|---|
| committer | Bryan Newbold <bnewbold@archive.org> | 2021-01-25 17:13:14 -0800 |
| commit | 5aed3803affdb3f05b881cb90496180be45da440 (patch) | |
| tree | 5a4de19de020ad063f5f85219ad24851ed7373c7 /fatcat_scholar/worker.py | |
| parent | 3340910073bca6483937ed6d9e5f5b5942833c2e (diff) | |
| download | fatcat-scholar-5aed3803affdb3f05b881cb90496180be45da440.tar.gz fatcat-scholar-5aed3803affdb3f05b881cb90496180be45da440.zip | |
refactor ES configuration setting names
Diffstat (limited to 'fatcat_scholar/worker.py')
| -rw-r--r-- | fatcat_scholar/worker.py | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/fatcat_scholar/worker.py b/fatcat_scholar/worker.py index 78b54d4..fb806a7 100644 --- a/fatcat_scholar/worker.py +++ b/fatcat_scholar/worker.py @@ -227,7 +227,7 @@ def main() -> None: fdw.run() elif args.worker == "index-docs-worker": es_client = elasticsearch.Elasticsearch( - settings.ELASTICSEARCH_BACKEND, timeout=25.0 + settings.ELASTICSEARCH_WRITE_BASE, timeout=25.0 ) idw = IndexDocsWorker( kafka_brokers=settings.KAFKA_BROKERS, @@ -235,7 +235,7 @@ def main() -> None: consume_topics=[f"scholar-{settings.SCHOLAR_ENV}.update-docs"], consumer_group=f"scholar-{settings.SCHOLAR_ENV}-index-workers", es_client=es_client, - es_index=settings.ELASTICSEARCH_FULLTEXT_INDEX, + es_index=settings.ELASTICSEARCH_WRITE_FULLTEXT_INDEX, ) idw.run() |