Skip to content

Commit

Permalink
Add initial command and run_command file
Browse files Browse the repository at this point in the history
  • Loading branch information
sultaniman committed Mar 4, 2024
1 parent 7e1163b commit 1bfef73
Show file tree
Hide file tree
Showing 2 changed files with 17 additions and 0 deletions.
11 changes: 11 additions & 0 deletions dlt/cli/_dlt.py
Original file line number Diff line number Diff line change
Expand Up @@ -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():
Expand Down
6 changes: 6 additions & 0 deletions dlt/cli/run_command.py
Original file line number Diff line number Diff line change
@@ -0,0 +1,6 @@
from dlt.cli.utils import track_command


@track_command(command="run")
def run_pipeline():
pass

0 comments on commit 1bfef73

Please sign in to comment.