Function show has a Cognitive Complexity of 18 (exceeds 5 allowed). Consider refactoring.

Open

def show(
    repo: "Repo",
    all_branches=False,
    all_tags=False,
    revs: Union[List[str], str, None] = None,

• Read up
  Read up

Function resolve_name has a Cognitive Complexity of 18 (exceeds 5 allowed). Consider refactoring.

Open

def resolve_name(
    scm: "Git",
    exp_names: Union[Iterable[str], str],
    git_remote: Optional[str] = None,
) -> Dict[str, Optional[ExpRefInfo]]:

• Read up
  Read up

Function apply has a Cognitive Complexity of 18 (exceeds 5 allowed). Consider refactoring.

Open

def apply(repo, rev, force=True, **kwargs):
    from scmrepo.exceptions import MergeConflictError

    from dvc.repo.checkout import checkout as dvc_checkout
    from dvc.scm import RevError, SCMError, resolve_rev

• Read up
  Read up

Function _sort_column has a Cognitive Complexity of 18 (exceeds 5 allowed). Consider refactoring.

Open

def _sort_column(sort_by, metric_names, param_names):
    path, _, sort_name = sort_by.rpartition(":")
    matches = set()

    if path:

• Read up
  Read up

URLInfo has 22 functions (exceeds 20 allowed). Consider refactoring.

Open

class URLInfo(_BasePath):
    DEFAULT_PORTS = {"http": 80, "https": 443, "ssh": 22, "hdfs": 0}

    def __init__(self, url):
        p = urlparse(url)

TmpDir has 22 functions (exceeds 20 allowed). Consider refactoring.

Open

class TmpDir(pathlib.Path):
    scheme = "local"

    @property
    def fs_path(self):

Function init has a Cognitive Complexity of 17 (exceeds 5 allowed). Consider refactoring.

Open

def init(
    repo: "Repo",
    name: str = "train",
    type: str = "default",  # pylint: disable=redefined-builtin
    defaults: Dict[str, str] = None,

• Read up
  Read up

Function _get_steps has a Cognitive Complexity of 17 (exceeds 5 allowed). Consider refactoring.

Open

def _get_steps(G, stages, downstream, single_item):
    import networkx as nx

    active = G.copy()
    if not single_item:

• Read up
  Read up

Function commit has a Cognitive Complexity of 17 (exceeds 5 allowed). Consider refactoring.

Open

    def commit(
        cls,
        scm: "Git",
        exp_hash: str,
        exp_name: Optional[str] = None,

• Read up
  Read up

Function _stash_exp has a Cognitive Complexity of 17 (exceeds 5 allowed). Consider refactoring.

Open

    def _stash_exp(
        self,
        *args,
        params: Optional[dict] = None,
        resume_rev: Optional[str] = None,

• Read up
  Read up

Function _check_circular_import has a Cognitive Complexity of 17 (exceeds 5 allowed). Consider refactoring.

Open

    def _check_circular_import(self, odb, obj_ids):
        from dvc.exceptions import CircularImportError
        from dvc.fs.dvc import DvcFileSystem
        from dvc_data.db.reference import ReferenceObjectDB
        from dvc_data.tree import Tree

• Read up
  Read up

File path_info.py has 259 lines of code (exceeds 250 allowed). Consider refactoring.

Open

# pylint: disable=protected-access
import os
import pathlib
import posixpath
from typing import Callable

File config_schema.py has 257 lines of code (exceeds 250 allowed). Consider refactoring.

Open

import os
from urllib.parse import urlparse

from funcy import walk_values
from voluptuous import (

Function add_parser has 53 lines of code (exceeds 25 allowed). Consider refactoring.

Open

def add_parser(subparsers, parent_parser):
    from dvc.commands.config import parent_config_parser

    machine_HELP = "Set up and manage cloud machines."
    machine_parser = subparsers.add_parser(

Function _ast_assign_to_dict has a Cognitive Complexity of 16 (exceeds 5 allowed). Consider refactoring.

Open

def _ast_assign_to_dict(assign, only_self_params=False, lineno=False):
    result = {}

    if isinstance(assign, ast.AnnAssign):
        name = _get_ast_name(assign.target, only_self_params)

• Read up
  Read up

Function parse_target has a Cognitive Complexity of 16 (exceeds 5 allowed). Consider refactoring.

Open

def parse_target(
    target: str, default: str = None, isa_glob: bool = False
) -> Tuple[Optional[str], Optional[str]]:
    from dvc.dvcfile import PIPELINE_FILE, PIPELINE_LOCK, is_valid_filename
    from dvc.exceptions import DvcException

• Read up
  Read up

Function ls has a Cognitive Complexity of 16 (exceeds 5 allowed). Consider refactoring.

Open

    def ls(  # pylint: disable=arguments-differ
        self, path, detail=True, dvc_only=False, **kwargs
    ):
        fs, fs_path, dvc_fs, dvc_path = self._get_fs_pair(path)

• Read up
  Read up

File __init__.py has 252 lines of code (exceeds 250 allowed). Consider refactoring.

Open

import csv
import io
import logging
import os
from collections import OrderedDict

Function makedirs has a Cognitive Complexity of 15 (exceeds 5 allowed). Consider refactoring.

Open

def makedirs(path, exist_ok=False, mode=None):
    if mode is None:
        os.makedirs(path, exist_ok=exist_ok)
        return

• Read up
  Read up

Function send_signal has a Cognitive Complexity of 15 (exceeds 5 allowed). Consider refactoring.

Open

    def send_signal(self, name: str, sig: int):
        """Send `signal` to the specified named process."""
        process_info = self[name]
        if sys.platform == "win32":
            if sig not in (

• Read up
  Read up