diff --git a/autopipe/__init__.py b/autopipe/__init__.py index c135565..5119759 100644 --- a/autopipe/__init__.py +++ b/autopipe/__init__.py @@ -1 +1,4 @@ from .autopipe import Autopipe +from input import * +from output import * +from pipe import * diff --git a/autopipe/__main__.py b/autopipe/__main__.py index ff15f00..87d6e54 100755 --- a/autopipe/__main__.py +++ b/autopipe/__main__.py @@ -1,5 +1,15 @@ #!/usr/bin/env python3 import autopipe +import logging +from argparse import ArgumentParser + if __name__ == "__main__": - autopipe.Autopipe() + parser = ArgumentParser(description="Easily run advanced pipelines in a daemon or in one run sessions.") + parser.add_argument("coordinator", help="The name of your pipeline coordinator.") + parser.add_argument("-v", "--verbose", choices=["debug", "info", "warn", "error"], nargs="?", const="info", + default="warn", dest="log_level", metavar="loglevel", + help="Set the logging level.", type=str.lower) + args = parser.parse_args() + + autopipe.Autopipe(args.coordinator, log_level=getattr(logging, args.log_level.upper())) diff --git a/autopipe/autopipe.py b/autopipe/autopipe.py index 4be2804..354dfbe 100644 --- a/autopipe/autopipe.py +++ b/autopipe/autopipe.py @@ -1,4 +1,8 @@ +import logging + + class Autopipe: - def __init__(self): + def __init__(self, coordinator, log_level=logging.WARNING): + logging.basicConfig(format="%(levelname)s: %(message)s", level=log_level) print("Hello from autopipe") - pass + logging.info(f"Using coordinator: {coordinator}") diff --git a/autopipe/input/__init__.py b/autopipe/input/__init__.py new file mode 100644 index 0000000..e69de29 diff --git a/autopipe/output/__init__.py b/autopipe/output/__init__.py new file mode 100644 index 0000000..e69de29 diff --git a/autopipe/pipe/__init__.py b/autopipe/pipe/__init__.py new file mode 100644 index 0000000..e69de29