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

Function match_queue_entry_by_name has a Cognitive Complexity of 23 (exceeds 5 allowed). Consider refactoring.

Open

    def match_queue_entry_by_name(
        self,
        exp_names: Collection[str],
        *entries: Iterable[Union[QueueEntry, QueueDoneResult]],
    ) -> dict[str, Optional[QueueEntry]]:

• Read up
  Read up

BaseStashQueue has 26 functions (exceeds 20 allowed). Consider refactoring.

Open

class BaseStashQueue(ABC):
    """Naive Git-stash based experiment queue.

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

Function _update_params has a Cognitive Complexity of 9 (exceeds 5 allowed). Consider refactoring.

Open

    def _update_params(self, params: dict[str, list[str]]):
        """Update param files with the provided `Hydra Override`_ patterns.

        Args:
            params: Dict mapping paths to `Hydra Override`_ patterns,

• Read up
  Read up

Function _stash_exp has 6 arguments (exceeds 4 allowed). Consider refactoring.

Open

    def _stash_exp(

Function init_executor has 5 arguments (exceeds 4 allowed). Consider refactoring.

Open

    def init_executor(

Function status has a Cognitive Complexity of 7 (exceeds 5 allowed). Consider refactoring.

Open

    def status(self) -> list[dict[str, Any]]:
        """Show the status of exp tasks in queue"""
        from datetime import datetime

        result: list[dict[str, Optional[str]]] = []

• Read up
  Read up

Function active_repo has a Cognitive Complexity of 7 (exceeds 5 allowed). Consider refactoring.

Open

    def active_repo(self, name: str) -> "Repo":
        """Return a Repo for the specified active experiment if it exists."""
        from dvc.exceptions import DvcException
        from dvc.repo import Repo
        from dvc.repo.experiments.exceptions import (

• Read up
  Read up