Function commit

dvc/repo/commit.py:46–87

(
    self,
    target=None,
    with_deps=False,
    recursive=False,
    force=False,
    allow_missing=False,
    data_only=False,
    relink=True,
)

@locked
def commit(
    self,
    target=None,
    with_deps=False,
    recursive=False,
    force=False,
    allow_missing=False,
    data_only=False,
    relink=True,
):
    committed_stages = []
    groups = groupby(
        [
            info
            for info in self.stage.collect_granular(
                target, with_deps=with_deps, recursive=recursive
            )
            if not data_only or info.stage.is_data_source
        ],
        key=lambda info: info.stage.dvcfile,
    )

    for dvcfile, stages_info_group in groups:
        to_dump = []
        for stage_info in stages_info_group:
            stage = stage_info.stage
            if force:
                stage.save(allow_missing=allow_missing)
            else:
                changes = stage.changed_entries()
                if any(changes):
                    prompt_to_commit(stage, changes, force=force)
                    stage.save(allow_missing=allow_missing)
            stage.commit(
                filter_info=stage_info.filter_info,
                allow_missing=allow_missing,
                relink=relink,
            )
            to_dump.append(stage)
        dvcfile.dump_stages(to_dump, update_pipeline=False)
        committed_stages.extend(to_dump)
    return committed_stages


@locked