From 4d7d97beb6274239f6364e6ab1a3478c4895c8b6 Mon Sep 17 00:00:00 2001 From: Sultan Iman Date: Mon, 4 Mar 2024 13:09:29 +0100 Subject: [PATCH] Add initial command and run_command file --- dlt/cli/_dlt.py | 11 +++++++++++ dlt/cli/run_command.py | 6 ++++++ 2 files changed, 17 insertions(+) create mode 100644 dlt/cli/run_command.py diff --git a/dlt/cli/_dlt.py b/dlt/cli/_dlt.py index 9894227046..3707ef38df 100644 --- a/dlt/cli/_dlt.py +++ b/dlt/cli/_dlt.py @@ -557,6 +557,17 @@ def main() -> int: subparsers.add_parser("telemetry", help="Shows telemetry status") + # Run pipeline + run_cmd = subparsers.add_parser("run", help="Run pipelines in a given directory") + + run_cmd.add_argument( + "module", + metavar="N", + type=str, + nargs="+", + help="Path to module or python file with pipelines", + ) + args = parser.parse_args() if Venv.is_virtual_env() and not Venv.is_venv_activated(): diff --git a/dlt/cli/run_command.py b/dlt/cli/run_command.py new file mode 100644 index 0000000000..0974f6e325 --- /dev/null +++ b/dlt/cli/run_command.py @@ -0,0 +1,6 @@ +from dlt.cli.utils import track_command + + +@track_command(command="run") +def run_pipeline(): + pass