Function run

dvc/repo/run.py:16–35

(
    self: "Repo",
    no_exec: bool = False,
    no_commit: bool = False,
    run_cache: bool = True,
    force: bool = True,
    **kwargs,
)

@locked
@scm_context
def run(
    self: "Repo",
    no_exec: bool = False,
    no_commit: bool = False,
    run_cache: bool = True,
    force: bool = True,
    **kwargs,
) -> Union["Stage", "PipelineStage"]:
    assert not kwargs.get("single_stage")
    assert not kwargs.get("fname")
    kwargs.update({"force": force, "params": parse_params(kwargs.get("params", []))})
    stage = self.stage.create(**kwargs)

    if no_exec:
        stage.ignore_outs()
    else:
        stage.run(no_commit=no_commit, run_cache=run_cache)

    stage.dump(update_lock=not no_exec)
    return stage