typing: first batch of python bulk type annotations

While these changes are more delicate than simple lint changes, this
specific batch of edits and annotations was *relatively* simple, and
resulted in few code changes other than function signature additions.

1 files changed, 6 insertions, 6 deletions

diff --git a/python/fatcat_worker.py b/python/fatcat_worker.py
index b776e0ce..0e2d03b5 100755
--- a/python/fatcat_worker.py
+++ b/python/fatcat_worker.py
@@ -18,7 +18,7 @@ from fatcat_tools.workers import (
 sentry_client = raven.Client()
 
 
-def run_changelog(args):
+def run_changelog(args: argparse.Namespace) -> None:
     topic = "fatcat-{}.changelog".format(args.env)
     worker = ChangelogWorker(
         args.api, args.kafka_hosts, topic, poll_interval=args.poll_interval
@@ -26,7 +26,7 @@ def run_changelog(args):
     worker.run()
 
 
-def run_entity_updates(args):
+def run_entity_updates(args: argparse.Namespace) -> None:
     changelog_topic = "fatcat-{}.changelog".format(args.env)
     release_topic = "fatcat-{}.release-updates-v03".format(args.env)
     file_topic = "fatcat-{}.file-updates".format(args.env)
@@ -46,7 +46,7 @@ def run_entity_updates(args):
     worker.run()
 
 
-def run_elasticsearch_release(args):
+def run_elasticsearch_release(args: argparse.Namespace) -> None:
     consume_topic = "fatcat-{}.release-updates-v03".format(args.env)
     worker = ElasticsearchReleaseWorker(
         args.kafka_hosts,
@@ -57,7 +57,7 @@ def run_elasticsearch_release(args):
     worker.run()
 
 
-def run_elasticsearch_container(args):
+def run_elasticsearch_container(args: argparse.Namespace) -> None:
     consume_topic = "fatcat-{}.container-updates".format(args.env)
     worker = ElasticsearchContainerWorker(
         args.kafka_hosts,
@@ -70,7 +70,7 @@ def run_elasticsearch_container(args):
     worker.run()
 
 
-def run_elasticsearch_changelog(args):
+def run_elasticsearch_changelog(args: argparse.Namespace) -> None:
     consume_topic = "fatcat-{}.changelog".format(args.env)
     worker = ElasticsearchChangelogWorker(
         args.kafka_hosts,
@@ -81,7 +81,7 @@ def run_elasticsearch_changelog(args):
     worker.run()
 
 
-def main():
+def main() -> None:
     parser = argparse.ArgumentParser(formatter_class=argparse.ArgumentDefaultsHelpFormatter)
     parser.add_argument(
         "--api-host-url", default="http://localhost:9411/v0", help="fatcat API host/port to use"