diff options
author | Bryan Newbold <bnewbold@robocracy.org> | 2019-01-08 14:12:15 -0800 |
---|---|---|
committer | Bryan Newbold <bnewbold@robocracy.org> | 2019-01-08 14:12:15 -0800 |
commit | a146ebbc3261f6cba6dc10e5a5524f6eca9ac98d (patch) | |
tree | 11a3dbdd4884c2c032144acafcaed003ac458ab6 /python/fatcat_worker.py | |
parent | 0e344762101e9cb1f57a139c726fd50f2364ad51 (diff) | |
download | fatcat-a146ebbc3261f6cba6dc10e5a5524f6eca9ac98d.tar.gz fatcat-a146ebbc3261f6cba6dc10e5a5524f6eca9ac98d.zip |
start refactoring API object passing
Diffstat (limited to 'python/fatcat_worker.py')
-rwxr-xr-x | python/fatcat_worker.py | 11 |
1 files changed, 9 insertions, 2 deletions
diff --git a/python/fatcat_worker.py b/python/fatcat_worker.py index e0ac48d8..3c4cacc1 100755 --- a/python/fatcat_worker.py +++ b/python/fatcat_worker.py @@ -1,21 +1,26 @@ #!/usr/bin/env python3 import sys +import raven import argparse import datetime +from fatcat_tools import public_api from fatcat_tools.workers import ChangelogWorker, EntityUpdatesWorker, ElasticsearchReleaseWorker +# Yep, a global. Gets DSN from `SENTRY_DSN` environment variable +sentry_client = raven.Client() + def run_changelog(args): topic = "fatcat-{}.changelog".format(args.env) - worker = ChangelogWorker(args.api_host_url, args.kafka_hosts, topic, + worker = ChangelogWorker(args.api, args.kafka_hosts, topic, args.poll_interval) worker.run() def run_entity_updates(args): changelog_topic = "fatcat-{}.changelog".format(args.env) release_topic = "fatcat-{}.release-updates".format(args.env) - worker = EntityUpdatesWorker(args.api_host_url, args.kafka_hosts, + worker = EntityUpdatesWorker(args.api, args.kafka_hosts, changelog_topic, release_topic) worker.run() @@ -64,6 +69,8 @@ def main(): if not args.__dict__.get("func"): print("tell me what to do!") sys.exit(-1) + + args.api = public_api(args.api_host_url) args.func(args) if __name__ == '__main__': |