Function _load_data_from_tree has a Cognitive Complexity of 322 (exceeds 5 allowed). Consider refactoring.

Open

def _load_data_from_tree(index, prefix, ws, key, tree, hash_name):
    from dvc_data.index import DataIndexEntry, Meta

    parents = set()

• Read up
  Read up

File output.py has 1212 lines of code (exceeds 250 allowed). Consider refactoring.

Open

import errno
import os
import posixpath
from collections import defaultdict
from contextlib import suppress

File index.py has 737 lines of code (exceeds 250 allowed). Consider refactoring.

Open

import logging
import time
from collections import defaultdict
from collections.abc import Iterable, Iterator
from functools import partial

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

Open

import logging
import os
import pickle
import shutil
from abc import ABC, abstractmethod

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

Open

import os
from abc import ABC, abstractmethod
from collections.abc import Collection, Generator, Iterable, Mapping
from dataclasses import asdict, dataclass
from typing import TYPE_CHECKING, Any, NamedTuple, Optional, Union

File celery.py has 531 lines of code (exceeds 250 allowed). Consider refactoring.

Open

import hashlib
import locale
import logging
import os
from collections import defaultdict

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

Open

import logging
import os
from collections.abc import Mapping, Sequence
from copy import deepcopy
from itertools import product

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

Open

import csv
import io
import os
from collections import defaultdict
from collections.abc import Iterator

File dvc.py has 453 lines of code (exceeds 250 allowed). Consider refactoring.

Open

import errno
import functools
import ntpath
import os
import posixpath

File context.py has 439 lines of code (exceeds 250 allowed). Consider refactoring.

Open

from abc import ABC, abstractmethod
from collections import defaultdict
from collections.abc import Mapping, MutableMapping, MutableSequence, Sequence
from contextlib import contextmanager
from copy import deepcopy

File data_sync.py has 400 lines of code (exceeds 250 allowed). Consider refactoring.

Open

import argparse

from dvc.cli import completion, formatter
from dvc.cli.command import CmdBase
from dvc.cli.utils import append_doc_link

LocalCeleryQueue has 39 functions (exceeds 20 allowed). Consider refactoring.

Open

class LocalCeleryQueue(BaseStashQueue):
    """DVC experiment queue.

    Maps queued experiments to (Git) stash reflog entries.
    """

Function match_defs_renderers has a Cognitive Complexity of 34 (exceeds 5 allowed). Consider refactoring.

Open

def match_defs_renderers(  # noqa: C901, PLR0912
    data,
    out=None,
    templates_dir: Optional["StrPath"] = None,
) -> list[RendererWithErrors]:

• Read up
  Read up

Function dumpd has a Cognitive Complexity of 34 (exceeds 5 allowed). Consider refactoring.

Open

    def dumpd(self, **kwargs):  # noqa: C901, PLR0912
        from dvc.cachemgr import LEGACY_HASH_NAMES

        ret: dict[str, Any] = {}
        with_files = (

• Read up
  Read up

File compare.py has 350 lines of code (exceeds 250 allowed). Consider refactoring.

Open

from collections import abc
from collections.abc import (
    ItemsView,
    Iterable,
    Iterator,

File ignore.py has 348 lines of code (exceeds 250 allowed). Consider refactoring.

Open

import os
import re
from collections import namedtuple
from itertools import chain, groupby, takewhile
from typing import TYPE_CHECKING, Optional

Experiments has 34 functions (exceeds 20 allowed). Consider refactoring.

Open

class Experiments:
    """Class that manages experiments in a DVC repo.

    Args:
        repo (dvc.repo.Repo): repo instance that these experiments belong to.

Output has 34 functions (exceeds 20 allowed). Consider refactoring.

Open

class Output:
    IS_DEPENDENCY = False

    PARAM_PATH = "path"
    PARAM_CACHE = "cache"

Function _ has a Cognitive Complexity of 29 (exceeds 5 allowed). Consider refactoring.

Open

def _(obj: dict, config=None):  # noqa: C901
    config = config or {}

    result = ""
    for k, v in flatten(obj).items():

• Read up
  Read up

File stage.py has 338 lines of code (exceeds 250 allowed). Consider refactoring.

Open

import fnmatch
import typing
from collections.abc import Iterable
from contextlib import suppress
from functools import wraps