diff options
| author | Bryan Newbold <bnewbold@robocracy.org> | 2019-03-04 18:53:01 -0800 |
|---|---|---|
| committer | Bryan Newbold <bnewbold@robocracy.org> | 2019-03-04 18:53:03 -0800 |
| commit | 30a8fc5f78eb15f641d6e8da0e7c0741d3f82b13 (patch) | |
| tree | 1f53b6e78875c36bcac8180a0aa5d211da824916 /python/fatcat_worker.py | |
| parent | 0ad7f9385bd9b459a4f6b23dbdfcaeacc58ebb69 (diff) | |
| download | fatcat-30a8fc5f78eb15f641d6e8da0e7c0741d3f82b13.tar.gz fatcat-30a8fc5f78eb15f641d6e8da0e7c0741d3f82b13.zip | |
elastic-release worker w/o API
Forgot that this worker really doesn't want/need any API connection at
all; just an ApiClient to deserialize objects from Kafka.
Diffstat (limited to 'python/fatcat_worker.py')
| -rwxr-xr-x | python/fatcat_worker.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/python/fatcat_worker.py b/python/fatcat_worker.py index cc8d05e8..d9d21c6d 100755 --- a/python/fatcat_worker.py +++ b/python/fatcat_worker.py @@ -27,7 +27,7 @@ def run_entity_updates(args): def run_elasticsearch_release(args): consume_topic = "fatcat-{}.release-updates".format(args.env) - worker = ElasticsearchReleaseWorker(args.api, args.kafka_hosts, consume_topic, + worker = ElasticsearchReleaseWorker(args.kafka_hosts, consume_topic, elasticsearch_backend=args.elasticsearch_backend, elasticsearch_index=args.elasticsearch_index) worker.run() |