SSHFileSystem has 25 functions (exceeds 20 allowed). Consider refactoring.

Open

class SSHFileSystem(BaseFileSystem):  # pylint:disable=abstract-method
    scheme = Schemes.SSH
    REQUIRES = {"paramiko": "paramiko"}
    _JOBS = 4

File base.py has 283 lines of code (exceeds 250 allowed). Consider refactoring.

Open

import os
from abc import ABC, abstractmethod
from typing import (
    TYPE_CHECKING,
    Callable,

File checkout.py has 283 lines of code (exceeds 250 allowed). Consider refactoring.

Open

import logging

from shortuuid import uuid

from dvc import prompt

Function _show_diff has a Cognitive Complexity of 20 (exceeds 5 allowed). Consider refactoring.

Open

    def _show_diff(diff, hide_missing=False):
        """
        Given a diff structure, generate a string of paths separated
        by new lines and grouped together by their state.

• Read up
  Read up

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

Open

def ls(repo, *args, rev=None, git_remote=None, all_=False, **kwargs):
    from dvc.scm.git import Git

    if rev:
        try:

• Read up
  Read up

Function _calculate_column_widths has a Cognitive Complexity of 20 (exceeds 5 allowed). Consider refactoring.

Open

    def _calculate_column_widths(
        self, console: "Console", options: "ConsoleOptions"
    ) -> List[int]:
        """Calculate the widths of each column, including padding, not
        including borders.

• Read up
  Read up

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

Open

import logging
import os
from typing import TYPE_CHECKING, Dict, List, Optional

from funcy import cached_property, first, project

LocalFileSystem has 24 functions (exceeds 20 allowed). Consider refactoring.

Open

class LocalFileSystem(BaseFileSystem):
    scheme = Schemes.LOCAL
    PATH_CLS = PathInfo
    PARAM_CHECKSUM = "md5"
    PARAM_PATH = "path"

Function reproduce has a Cognitive Complexity of 19 (exceeds 5 allowed). Consider refactoring.

Open

    def reproduce(
        cls,
        dvc_dir: Optional[str],
        rev: str,
        queue: Optional["Queue"] = None,

• Read up
  Read up

File connection.py has 272 lines of code (exceeds 250 allowed). Consider refactoring.

Open

import errno
import logging
import os
import posixpath
import shlex

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

Open

def checkout(
    path_info,
    fs,
    obj,
    cache,

• Read up
  Read up

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

Open

def _clone_default_branch(url, rev, for_write=False):
    """Get or create a clean clone of the url.

    The cloned is reactualized with git pull unless rev is a known sha.
    """

• 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)

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

Open

class FSSpecWrapper(BaseFileSystem):
    TRAVERSE_PREFIX_LEN = 2

    def __init__(self, **kwargs):
        super().__init__(**kwargs)

File utils.py has 263 lines of code (exceeds 250 allowed). Consider refactoring.

Open

import os
import pathlib
from contextlib import suppress
from typing import TYPE_CHECKING, Union

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 apply has a Cognitive Complexity of 17 (exceeds 5 allowed). Consider refactoring.

Open

def apply(repo, rev, force=True, **kwargs):
    from dvc.repo.checkout import checkout as dvc_checkout
    from dvc.scm.base import MergeConflictError, SCMError

    exps = repo.experiments

• Read up
  Read up

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

Open

    def checkout_index(
        self,
        paths: Optional[Iterable[str]] = None,
        force: bool = False,
        ours: bool = False,

• 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