iterative__dvc-8904

{
  "status": "ok",
  "stdout": "Stdout: \nStderr: ERROR: Stage 'build@2021' not found inside 'dvc.yaml' file\n\n",
  "stderr": "",
  "exit_code": 0
}

{
  "status": "ok",
  "stdout": "dvc/repo/stage.py:230:        if accept_group and stages.is_foreach_generated(name):\ndvc/repo/stage.py:249:                foreach are returned.\ndvc/repo/stage.py:308:                - a foreach group name or a stage name in the `dvc.yaml` file.\ndvc/repo/stage.py:309:                - a generated stage name from a foreach group.\ndvc/repo/stage.py:356:        - foreach_group_name or stage_name\ndvc/repo/stage.py:357:        - generated stage name from a foreach group\ndvc/parsing/__init__.py:53:FOREACH_KWD = \"foreach\"\ndvc/parsing/__init__.py:108:def split_foreach_name(name: str) -> Tuple[str, Optional[str]]:\ndvc/parsing/__init__.py:170:        group, key = split_foreach_name(name)\ndvc/parsing/__init__.py:192:        return self._has_group_and_key(*split_foreach_name(key))\ndvc/parsing/__init__.py:258:            # but for foreach-generated ones, once is enough, which it does\ndvc/parsing/__init__.py:330:        self.foreach_data = definition[FOREACH_KWD]\ndvc/parsing/__init__.py:338:        # optimization: check for syntax errors only once for `foreach` stages\ndvc/parsing/__init__.py:344:        return self._resolve_foreach_data()\ndvc/parsing/__init__.py:346:    def _resolve_foreach_data(self) -> \"SeqOrMap\":\ndvc/parsing/__init__.py:348:            iterable = self.context.resolve(self.foreach_data, unwrap=False)\ndvc/parsing/__init__.py:350:            format_and_raise(exc, f\"'{self.where}.{self.name}.foreach'\", self.relpath)\ndvc/parsing/__init__.py:352:        # foreach data can be a resolved dictionary/list.\ndvc/parsing/__init__.py:354:        # foreach stages will have `item` and `key` added to the context\ndvc/parsing/__init__.py:366:                f\"failed to resolve '{self.where}.{self.name}.foreach'\"\ndvc/parsing/__init__.py:421:        err_message = f\"Could not find '{key}' in foreach group '{self.name}'\"\ndvc/parsing/__init__.py:425:        # NOTE: we need to use resolved iterable/foreach-data,\ndvc/parsing/__init__.py:446:                # optimization: skip checking for syntax errors on each foreach\ndvc/parsing/interpolate.py:201:    not_foreach = key is not None and \"foreach\" not in key\ndvc/parsing/interpolate.py:202:    if not_primitive and not_foreach:\ndvc/stage/loader.py:174:    def is_foreach_generated(self, name: str):\n",
  "stderr": "",
  "exit_code": 0
}

{
  "status": "error",
  "error_type": "CommandError",
  "error_message": "",
  "details": {
    "stdout": "",
    "stderr": "",
    "exit_code": 1
  }
}

{
  "status": "ok",
  "filepath": "dvc/parsing/__init__.py",
  "content": "            format_and_raise(exc, f\"'{where}.{name}.{key}'\", path)\n\n\ndef is_map_or_seq(data: Any) -> bool:\n    _is_map_or_seq = isa(Mapping, Sequence)\n    return not isinstance(data, str) and _is_map_or_seq(data)\n\n\ndef split_foreach_name(name: str) -> Tuple[str, Optional[str]]:\n    group, *keys = name.rsplit(JOIN, maxsplit=1)\n    return group, first(keys)\n\n\ndef check_interpolations(data: \"DictStrAny\", where: str, path: str):\n    def func(s: \"DictStrAny\") -> None:\n        if is_interpolated_string(s):\n            raise ResolveError(\n                _format_preamble(f\"'{where}'\", path) + \"interpolating is not allowed\"\n            )\n\n    return recurse(func)(data)\n\n\nDefinition = Union[\"ForeachDefinition\", \"EntryDefinition\"]\n\n\ndef make_definition(\n    resolver: \"DataResolver\", name: str, definition: \"DictStrAny\", **kwargs\n) -> Definition:\n    args = resolver, resolver.context, name, definition\n    if FOREACH_KWD in definition:\n        return ForeachDefinition(*args, **kwargs)\n    return EntryDefinition(*args, **kwargs)\n\n\nclass DataResolver:\n    def __init__(self, repo: \"Repo\", wdir: str, d: dict):\n        self.fs = fs = repo.fs\n\n        if os.path.isabs(wdir):\n            wdir = fs.path.relpath(wdir)\n            wdir = \"\" if wdir == os.curdir else wdir\n\n        self.wdir = wdir\n        self.relpath = fs.path.normpath(fs.path.join(self.wdir, \"dvc.yaml\"))\n\n        vars_ = d.get(VARS_KWD, [])\n        check_interpolations(vars_, VARS_KWD, self.relpath)\n        self.context: Context = Context()\n\n        try:\n            args = fs, vars_, wdir  # load from `vars` section\n            self.context.load_from_vars(*args, default=DEFAULT_PARAMS_FILE)\n        except ContextError as exc:\n            format_and_raise(exc, \"'vars'\", self.relpath)\n\n        # we use `tracked_vars` to keep a dictionary of used variables\n        # by the interpolated entries.\n        self.tracked_vars: Dict[str, Mapping] = {}\n\n        stages_data = d.get(STAGES_KWD, {})\n        # we wrap the definitions into ForeachDefinition and EntryDefinition,\n        # that helps us to optimize, cache and selectively load each one of\n        # them as we need, and simplify all of this DSL/parsing logic.\n        self.definitions: Dict[str, Definition] = {\n            name: make_definition(self, name, definition)\n            for name, definition in stages_data.items()\n        }\n\n    def resolve_one(self, name: str):\n        group, key = split_foreach_name(name)\n\n        if not self._has_group_and_key(group, key):\n            raise EntryNotFound(f\"Could not find '{name}'\")\n\n        # all of the checks for `key` not being None for `ForeachDefinition`\n        # and/or `group` not existing in the `interim`, etc. should be\n        # handled by the `self.has_key()` above.\n        definition = self.definitions[group]\n        if isinstance(definition, EntryDefinition):\n            return definition.resolve()\n\n        assert key\n        return definition.resolve_one(key)\n\n    def resolve(self):\n        \"\"\"Used for testing purposes, otherwise use resolve_one().\"\"\"\n        data = join(map(self.resolve_one, self.get_keys()))\n        logger.trace(\"Resolved dvc.yaml:\\n%s\", data)  # type: ignore[attr-defined]\n        return {STAGES_KWD: data}\n\n    def has_key(self, key: str):\n        return self._has_group_and_key(*split_foreach_name(key))\n\n    def _has_group_and_key(self, group: str, key: Optional[str] = None):\n        try:\n            definition = self.definitions[group]\n        except KeyError:\n            return False\n\n        if key:\n            return isinstance(definition, ForeachDefinition) and definition.has_member(\n                key\n            )\n        return not isinstance(definition, ForeachDefinition)\n\n    @collecting\n    def get_keys(self):\n        for name, definition in self.definitions.items():\n            if isinstance(definition, ForeachDefinition):\n                yield from definition.get_generated_names()\n                continue\n            yield name\n\n    def track_vars(self, name: str, vars_) -> None:\n        self.tracked_vars[name] = vars_\n\n\nclass EntryDefinition:\n    def __init__(\n        self,\n        resolver: DataResolver,\n        context: Context,\n        name: str,\n        definition: \"DictStrAny\",\n        where: str = STAGES_KWD,\n    ):\n        self.resolver = resolver\n        self.wdir = self.resolver.wdir\n        self.relpath = self.resolver.relpath\n        self.context = context\n        self.name = name\n        self.definition = definition\n        self.where = where\n\n    def _resolve_wdir(\n        self, context: Context, name: str, wdir: Optional[str] = None\n    ) -> str:\n        if not wdir:\n            return self.wdir\n\n        try:\n            wdir = to_str(context.resolve_str(wdir))\n        except (ContextError, ParseError) as exc:\n            format_and_raise(exc, f\"'{self.where}.{name}.wdir'\", self.relpath)\n        return self.resolver.fs.path.join(self.wdir, wdir)\n\n    def resolve(self, **kwargs):\n        try:\n            return self.resolve_stage(**kwargs)",
  "start_line": 100,
  "end_line": 249,
  "total_lines": 455,
  "is_truncated": true
}

{
  "status": "ok",
  "filepath": "dvc/parsing/__init__.py",
  "content": "import logging\nimport os\nfrom collections.abc import Mapping, Sequence\nfrom copy import deepcopy\nfrom typing import (\n    TYPE_CHECKING,\n    Any,\n    Dict,\n    List,\n    NamedTuple,\n    Optional,\n    Tuple,\n    Type,\n    Union,\n)\n\nfrom funcy import collecting, first, isa, join, reraise\n\nfrom dvc.exceptions import DvcException\nfrom dvc.parsing.interpolate import ParseError\nfrom dvc.utils.objects import cached_property\n\nfrom .context import (\n    Context,\n    ContextError,\n    KeyNotInContext,\n    MergeError,\n    Node,\n    VarsAlreadyLoaded,\n)\nfrom .interpolate import (\n    check_recursive_parse_errors,\n    is_interpolated_string,\n    recurse,\n    to_str,\n)\n\nif TYPE_CHECKING:\n    from typing import NoReturn\n\n    from dvc.repo import Repo\n    from dvc.types import DictStrAny\n\n    from .context import SeqOrMap\n\n\nlogger = logging.getLogger(__name__)\n\nSTAGES_KWD = \"stages\"\nVARS_KWD = \"vars\"\nWDIR_KWD = \"wdir\"\nPARAMS_KWD = \"params\"\nFOREACH_KWD = \"foreach\"\nDO_KWD = \"do\"\n\nDEFAULT_PARAMS_FILE = \"params.yaml\"\n\nJOIN = \"@\"\n\n\nclass ResolveError(DvcException):\n    pass\n\n\nclass EntryNotFound(DvcException):\n    pass\n\n\ndef _format_preamble(msg: str, path: str, spacing: str = \" \") -> str:\n    return f\"failed to parse {msg} in '{path}':{spacing}\"\n\n\ndef format_and_raise(exc: Exception, msg: str, path: str) -> \"NoReturn\":\n    spacing = (\n        \"\\n\" if isinstance(exc, (ParseError, MergeError, VarsAlreadyLoaded)) else \" \"\n    )\n    message = _format_preamble(msg, path, spacing) + str(exc)\n\n    # FIXME: cannot reraise because of how we log \"cause\" of the exception\n    # the error message is verbose, hence need control over the spacing\n    _reraise_err(ResolveError, message, from_exc=exc)\n\n\ndef _reraise_err(\n    exc_cls: Type[Exception], *args, from_exc: Optional[Exception] = None\n) -> \"NoReturn\":\n    err = exc_cls(*args)\n    if from_exc and logger.isEnabledFor(logging.DEBUG):\n        raise err from from_exc\n    raise err\n\n\ndef check_syntax_errors(\n    definition: \"DictStrAny\", name: str, path: str, where: str = \"stages\"\n):\n    for key, d in definition.items():\n        try:\n            check_recursive_parse_errors(d)\n        except ParseError as exc:\n            format_and_raise(exc, f\"'{where}.{name}.{key}'\", path)\n\n\ndef is_map_or_seq(data: Any) -> bool:\n    _is_map_or_seq = isa(Mapping, Sequence)\n    return not isinstance(data, str) and _is_map_or_seq(data)\n\n\ndef split_foreach_name(name: str) -> Tuple[str, Optional[str]]:\n    group, *keys = name.rsplit(JOIN, maxsplit=1)\n    return group, first(keys)\n\n\ndef check_interpolations(data: \"DictStrAny\", where: str, path: str):\n    def func(s: \"DictStrAny\") -> None:\n        if is_interpolated_string(s):\n            raise ResolveError(\n                _format_preamble(f\"'{where}'\", path) + \"interpolating is not allowed\"\n            )\n\n    return recurse(func)(data)\n\n\nDefinition = Union[\"ForeachDefinition\", \"EntryDefinition\"]\n\n\ndef make_definition(\n    resolver: \"DataResolver\", name: str, definition: \"DictStrAny\", **kwargs\n) -> Definition:\n    args = resolver, resolver.context, name, definition\n    if FOREACH_KWD in definition:\n        return ForeachDefinition(*args, **kwargs)\n    return EntryDefinition(*args, **kwargs)\n\n\nclass DataResolver:\n    def __init__(self, repo: \"Repo\", wdir: str, d: dict):\n        self.fs = fs = repo.fs\n\n        if os.path.isabs(wdir):\n            wdir = fs.path.relpath(wdir)\n            wdir = \"\" if wdir == os.curdir else wdir\n\n        self.wdir = wdir\n        self.relpath = fs.path.normpath(fs.path.join(self.wdir, \"dvc.yaml\"))\n\n        vars_ = d.get(VARS_KWD, [])\n        check_interpolations(vars_, VARS_KWD, self.relpath)\n        self.context: Context = Context()\n\n        try:",
  "start_line": 1,
  "end_line": 150,
  "total_lines": 455,
  "is_truncated": true
}

{
  "status": "ok",
  "filepath": "dvc/parsing/__init__.py",
  "content": "import logging\nimport os\nfrom collections.abc import Mapping, Sequence\nfrom copy import deepcopy\nfrom typing import (\n    TYPE_CHECKING,\n    Any,\n    Dict,\n    List,\n    NamedTuple,\n    Optional,\n    Tuple,\n    Type,\n    Union,\n)\n\nfrom funcy import collecting, first, isa, join, reraise\n\nfrom dvc.exceptions import DvcException\nfrom dvc.parsing.interpolate import ParseError\nfrom dvc.utils.objects import cached_property\n\nfrom .context import (\n    Context,\n    ContextError,\n    KeyNotInContext,\n    MergeError,\n    Node,\n    VarsAlreadyLoaded,\n)\nfrom .interpolate import (\n    check_recursive_parse_errors,\n    is_interpolated_string,\n    recurse,\n    to_str,\n)\n\nif TYPE_CHECKING:\n    from typing import NoReturn\n\n    from dvc.repo import Repo\n    from dvc.types import DictStrAny\n\n    from .context import SeqOrMap\n\n\nlogger = logging.getLogger(__name__)\n\nSTAGES_KWD = \"stages\"\nVARS_KWD = \"vars\"\nWDIR_KWD = \"wdir\"\nPARAMS_KWD = \"params\"\nFOREACH_KWD = \"foreach\"\nDO_KWD = \"do\"\n\nDEFAULT_PARAMS_FILE = \"params.yaml\"\n\nJOIN = \"@\"\n\n\nclass ResolveError(DvcException):\n    pass\n\n\nclass EntryNotFound(DvcException):\n    pass\n\n\ndef _format_preamble(msg: str, path: str, spacing: str = \" \") -> str:\n    return f\"failed to parse {msg} in '{path}':{spacing}\"\n\n\ndef format_and_raise(exc: Exception, msg: str, path: str) -> \"NoReturn\":\n    spacing = (\n        \"\\n\" if isinstance(exc, (ParseError, MergeError, VarsAlreadyLoaded)) else \" \"\n    )\n    message = _format_preamble(msg, path, spacing) + str(exc)\n\n    # FIXME: cannot reraise because of how we log \"cause\" of the exception\n    # the error message is verbose, hence need control over the spacing\n    _reraise_err(ResolveError, message, from_exc=exc)\n\n\ndef _reraise_err(\n    exc_cls: Type[Exception], *args, from_exc: Optional[Exception] = None\n) -> \"NoReturn\":\n    err = exc_cls(*args)\n    if from_exc and logger.isEnabledFor(logging.DEBUG):\n        raise err from from_exc\n    raise err\n\n\ndef check_syntax_errors(\n    definition: \"DictStrAny\", name: str, path: str, where: str = \"stages\"\n):\n    for key, d in definition.items():\n        try:\n            check_recursive_parse_errors(d)\n        except ParseError as exc:\n            format_and_raise(exc, f\"'{where}.{name}.{key}'\", path)\n\n\ndef is_map_or_seq(data: Any) -> bool:\n    _is_map_or_seq = isa(Mapping, Sequence)\n    return not isinstance(data, str) and _is_map_or_seq(data)\n\n\ndef split_foreach_name(name: str) -> Tuple[str, Optional[str]]:\n    group, *keys = name.rsplit(JOIN, maxsplit=1)\n    return group, first(keys)\n\n\ndef check_interpolations(data: \"DictStrAny\", where: str, path: str):\n    def func(s: \"DictStrAny\") -> None:\n        if is_interpolated_string(s):\n            raise ResolveError(\n                _format_preamble(f\"'{where}'\", path) + \"interpolating is not allowed\"\n            )\n\n    return recurse(func)(data)\n\n\nDefinition = Union[\"ForeachDefinition\", \"EntryDefinition\"]\n\n\ndef make_definition(\n    resolver: \"DataResolver\", name: str, definition: \"DictStrAny\", **kwargs\n) -> Definition:\n    args = resolver, resolver.context, name, definition\n    if FOREACH_KWD in definition:\n        return ForeachDefinition(*args, **kwargs)\n    return EntryDefinition(*args, **kwargs)\n\n\nclass DataResolver:\n    def __init__(self, repo: \"Repo\", wdir: str, d: dict):\n        self.fs = fs = repo.fs\n\n        if os.path.isabs(wdir):\n            wdir = fs.path.relpath(wdir)\n            wdir = \"\" if wdir == os.curdir else wdir\n\n        self.wdir = wdir\n        self.relpath = fs.path.normpath(fs.path.join(self.wdir, \"dvc.yaml\"))\n\n        vars_ = d.get(VARS_KWD, [])\n        check_interpolations(vars_, VARS_KWD, self.relpath)\n        self.context: Context = Context()\n\n        try:",
  "start_line": 1,
  "end_line": 150,
  "total_lines": 455,
  "is_truncated": true
}

{
  "status": "ok",
  "filepath": "dvc/parsing/__init__.py",
  "content": "        self, context: \"Context\", value: Any, key: str, skip_checks: bool\n    ) -> \"DictStrAny\":\n        try:\n            return context.resolve(\n                value, skip_interpolation_checks=skip_checks, key=key\n            )\n        except (ParseError, KeyNotInContext) as exc:\n            format_and_raise(exc, f\"'{self.where}.{self.name}.{key}'\", self.relpath)\n\n\nclass IterationPair(NamedTuple):\n    key: str = \"key\"\n    value: str = \"item\"\n\n\nclass ForeachDefinition:\n    def __init__(\n        self,\n        resolver: DataResolver,\n        context: Context,\n        name: str,\n        definition: \"DictStrAny\",\n        where: str = STAGES_KWD,\n    ):\n        self.resolver = resolver\n        self.relpath = self.resolver.relpath\n        self.context = context\n        self.name = name\n\n        assert DO_KWD in definition\n        self.foreach_data = definition[FOREACH_KWD]\n        self._do_definition = definition[DO_KWD]\n\n        self.pair = IterationPair()\n        self.where = where\n\n    @cached_property\n    def do_definition(self):\n        # optimization: check for syntax errors only once for `foreach` stages\n        check_syntax_errors(self._do_definition, self.name, self.relpath)\n        return self._do_definition\n\n    @cached_property\n    def resolved_iterable(self):\n        return self._resolve_foreach_data()\n\n    def _resolve_foreach_data(self) -> \"SeqOrMap\":\n        try:\n            iterable = self.context.resolve(self.foreach_data, unwrap=False)\n        except (ContextError, ParseError) as exc:\n            format_and_raise(exc, f\"'{self.where}.{self.name}.foreach'\", self.relpath)\n\n        # foreach data can be a resolved dictionary/list.\n        self._check_is_map_or_seq(iterable)\n        # foreach stages will have `item` and `key` added to the context\n        # so, we better warn them if they have them already in the context\n        # from the global vars. We could add them in `set_temporarily`, but\n        # that'd make it display for each iteration.\n        self._warn_if_overwriting(self._inserted_keys(iterable))\n        return iterable\n\n    def _check_is_map_or_seq(self, iterable):\n        if not is_map_or_seq(iterable):\n            node = iterable.value if isinstance(iterable, Node) else iterable\n            typ = type(node).__name__\n            raise ResolveError(\n                f\"failed to resolve '{self.where}.{self.name}.foreach'\"\n                f\" in '{self.relpath}': expected list/dictionary, got \" + typ\n            )\n\n    def _warn_if_overwriting(self, keys: List[str]):\n        warn_for = [k for k in keys if k in self.context]\n        if warn_for:\n            linking_verb = \"is\" if len(warn_for) == 1 else \"are\"\n            logger.warning(\n                (\n                    \"%s %s already specified, \"\n                    \"will be overwritten for stages generated from '%s'\"\n                ),\n                \" and \".join(warn_for),\n                linking_verb,\n                self.name,\n            )\n\n    def _inserted_keys(self, iterable) -> List[str]:\n        keys = [self.pair.value]\n        if isinstance(iterable, Mapping):\n            keys.append(self.pair.key)\n        return keys\n\n    @cached_property\n    def normalized_iterable(self):\n        \"\"\"Convert sequence to Mapping with keys normalized.\"\"\"\n        iterable = self.resolved_iterable\n        if isinstance(iterable, Mapping):\n            return iterable\n\n        assert isinstance(iterable, Sequence)\n        if any(map(is_map_or_seq, iterable)):\n            # if the list contains composite data, index are the keys\n            return {to_str(idx): value for idx, value in enumerate(iterable)}\n\n        # for simple lists, eg: [\"foo\", \"bar\"],  contents are the key itself\n        return {to_str(value): value for value in iterable}\n\n    def has_member(self, key: str) -> bool:\n        return key in self.normalized_iterable\n\n    def get_generated_names(self):\n        return list(map(self._generate_name, self.normalized_iterable))\n\n    def _generate_name(self, key: str) -> str:\n        return f\"{self.name}{JOIN}{key}\"\n\n    def resolve_all(self) -> \"DictStrAny\":\n        return join(map(self.resolve_one, self.normalized_iterable))\n\n    def resolve_one(self, key: str) -> \"DictStrAny\":\n        return self._each_iter(key)\n\n    def _each_iter(self, key: str) -> \"DictStrAny\":\n        err_message = f\"Could not find '{key}' in foreach group '{self.name}'\"\n        with reraise(KeyError, EntryNotFound(err_message)):\n            value = self.normalized_iterable[key]\n\n        # NOTE: we need to use resolved iterable/foreach-data,\n        # not the normalized ones to figure out whether to make item/key\n        # available\n        inserted = self._inserted_keys(self.resolved_iterable)\n        temp_dict = {self.pair.value: value}\n        key_str = self.pair.key\n        if key_str in inserted:\n            temp_dict[key_str] = key\n\n        with self.context.set_temporarily(temp_dict, reserve=True):\n            # optimization: item and key can be removed on __exit__() as they\n            # are top-level values, and are not merged recursively.\n            # This helps us avoid cloning context, which is slower\n            # (increasing the size of the context might increase\n            # the no. of items to be generated which means more cloning,\n            # i.e. quadratic complexity).\n            generated = self._generate_name(key)\n            entry = EntryDefinition(\n                self.resolver, self.context, generated, self.do_definition\n            )\n            try:\n                # optimization: skip checking for syntax errors on each foreach\n                # generated stages. We do it once when accessing do_definition.\n                return entry.resolve_stage(skip_checks=True)\n            except ContextError as exc:",
  "start_line": 300,
  "end_line": 449,
  "total_lines": 455,
  "is_truncated": true
}

{
  "status": "ok",
  "filepath": "dvc/parsing/interpolate.py",
  "content": "\n    try:\n        result = get_parser().parseString(s, parseAll=True)\n    except ParseException as exc:\n        format_and_raise_parse_error(exc)\n        raise AssertionError(\"unreachable\")  # noqa: B904\n\n    joined = result.asList()\n    assert len(joined) == 1\n    return joined[0]\n\n\ndef get_expression(match: \"Match\", skip_checks: bool = False):\n    inner = match[\"inner\"]\n    return inner if skip_checks else parse_expr(inner)\n\n\ndef validate_value(value, key):\n    from .context import PRIMITIVES\n\n    not_primitive = value is not None and not isinstance(value, PRIMITIVES)",
  "start_line": 180,
  "end_line": 200,
  "total_lines": 230,
  "is_truncated": false
}

{
  "status": "ok",
  "stdout": "85:def to_str(obj) -> str:\n",
  "stderr": "",
  "exit_code": 0
}

{
  "status": "ok",
  "filepath": "dvc/parsing/interpolate.py",
  "content": "\n    return quote(value)\n\n\n@singledispatch\ndef to_str(obj) -> str:\n    return str(obj)\n\n\n@to_str.register(bool)\ndef _(obj: bool):\n    return \"true\" if obj else \"false\"\n\n\n@to_str.register(dict)\ndef _(obj: dict):  # noqa: C901\n    from dvc.config import Config\n\n    config = Config().get(\"parsing\", {})\n\n    result = \"\"",
  "start_line": 80,
  "end_line": 100,
  "total_lines": 230,
  "is_truncated": false
}

{
  "status": "ok",
  "filepath": "dvc/parsing/__init__.py",
  "occurrences": 1,
  "strategy": "exact",
  "diff": "--- a/dvc/parsing/__init__.py\n+++ b/dvc/parsing/__init__.py\n@@ -392,7 +392,7 @@\n         \"\"\"Convert sequence to Mapping with keys normalized.\"\"\"\n         iterable = self.resolved_iterable\n         if isinstance(iterable, Mapping):\n-            return iterable\n+            return {to_str(k): v for k, v in iterable.items()}\n \n         assert isinstance(iterable, Sequence)\n         if any(map(is_map_or_seq, iterable)):\n",
  "is_truncated": false
}

{
  "status": "ok",
  "stdout": "On branch master\nChanges not staged for commit:\n  (use \"git add <file>...\" to update what will be committed)\n  (use \"git restore <file>...\" to discard changes in working directory)\n\tmodified:   dvc/parsing/__init__.py\n\nno changes added to commit (use \"git add\" and/or \"git commit -a\")\n",
  "stderr": "",
  "exit_code": 0
}

{
  "status": "error",
  "error_type": "CommandError",
  "error_message": "hint: Using 'master' as the name for the initial branch. This default branch name\nhint: is subject to change. To configure the initial branch name to use in all\nhint: of your new repositories, which will suppress this warning, call:\nhint: \nhint: \tgit config --global init.defaultBranch <name>\nhint: \nhint: Names commonly chosen instead of 'master' are 'main', 'trunk' and\nhint: 'development'. The just-created branch can be renamed via this command:\nhint: \nhint: \tgit branch -m <name>\nERROR: failed to initiate DVC - '.dvc' exists. Use `-f` to force.\n",
  "details": {
    "stdout": "Initialized empty Git repository in /tmp/dvc_repro/.git/\n",
    "stderr": "hint: Using 'master' as the name for the initial branch. This default branch name\nhint: is subject to change. To configure the initial branch name to use in all\nhint: of your new repositories, which will suppress this warning, call:\nhint: \nhint: \tgit config --global init.defaultBranch <name>\nhint: \nhint: Names commonly chosen instead of 'master' are 'main', 'trunk' and\nhint: 'development'. The just-created branch can be renamed via this command:\nhint: \nhint: \tgit branch -m <name>\nERROR: failed to initiate DVC - '.dvc' exists. Use `-f` to force.\n",
    "exit_code": 1
  }
}

{
  "status": "ok",
  "stdout": "Initialized empty Git repository in /tmp/dvc_repro_123/.git/\nInitialized DVC repository.\n\n+---------------------------------------------------------------------+\n|                                                                     |\n|        DVC has enabled anonymous aggregate usage analytics.         |\n|     Read the analytics documentation (and how to opt-out) here:     |\n|             <https://dvc.org/doc/user-guide/analytics>              |\n|                                                                     |\n+---------------------------------------------------------------------+\n\nWhat's next?\n------------\n- Check out the documentation: <https://dvc.org/doc>\n- Get help and share ideas: <https://dvc.org/chat>\n- Star us on GitHub: <https://github.com/iterative/dvc>\nbuild@2021:\n\tchanged deps:\n\t\tdeleted:            data/{key}.csv\nbuild@2022:\n\tchanged deps:\n\t\tdeleted:            data/{key}.csv\n",
  "stderr": "hint: Using 'master' as the name for the initial branch. This default branch name\nhint: is subject to change. To configure the initial branch name to use in all\nhint: of your new repositories, which will suppress this warning, call:\nhint: \nhint: \tgit config --global init.defaultBranch <name>\nhint: \nhint: Names commonly chosen instead of 'master' are 'main', 'trunk' and\nhint: 'development'. The just-created branch can be renamed via this command:\nhint: \nhint: \tgit branch -m <name>\n",
  "exit_code": 0
}

{
  "status": "ok",
  "stdout": "./tests/func/parsing/test_foreach.py:6:from dvc.parsing import DEFAULT_PARAMS_FILE, DataResolver, ForeachDefinition\n./tests/func/parsing/test_foreach.py:16:    definition = ForeachDefinition(resolver, context, \"build\", data)\n./tests/func/parsing/test_foreach.py:32:    definition = ForeachDefinition(resolver, context, \"build\", data)\n./tests/func/parsing/test_foreach.py:53:    definition = ForeachDefinition(resolver, context, \"build\", data)\n./tests/func/parsing/test_foreach.py:69:    definition = ForeachDefinition(resolver, resolver.context, \"build\", data)\n./tests/func/parsing/test_foreach.py:103:    definition = ForeachDefinition(resolver, resolver.context, \"build\", data)\n./tests/func/parsing/test_foreach.py:117:    definition = ForeachDefinition(resolver, resolver.context, \"build\", data)\n./tests/func/parsing/test_foreach.py:138:    definition = ForeachDefinition(resolver, resolver.context, \"build\", data)\n./tests/func/parsing/test_foreach.py:155:    definition = ForeachDefinition(resolver, resolver.context, \"build\", data)\n./tests/func/parsing/test_foreach.py:169:    definition = ForeachDefinition(resolver, resolver.context, \"build\", data)\n./tests/func/parsing/test_foreach.py:185:    definition = ForeachDefinition(resolver, resolver.context, \"build\", data)\n./tests/func/parsing/test_foreach.py:211:    definition = ForeachDefinition(resolver, resolver.context, \"build\", data)\n./tests/func/parsing/test_foreach.py:242:    definition = ForeachDefinition(resolver, resolver.context, \"build\", data)\n./tests/func/parsing/test_foreach.py:266:    definition = ForeachDefinition(resolver, resolver.context, \"build\", data)\n./tests/func/parsing/test_foreach.py:298:    definition = ForeachDefinition(resolver, resolver.context, \"build\", data)\n./tests/func/parsing/test_foreach.py:335:    definition = ForeachDefinition(resolver, resolver.context, \"build\", data)\n./tests/func/parsing/test_foreach.py:387:    definition = ForeachDefinition(\n./tests/func/parsing/test_foreach.py:399:    definition = ForeachDefinition(\n./tests/func/parsing/__init__.py:1:from dvc.parsing import DataResolver, EntryDefinition, ForeachDefinition\n./tests/func/parsing/__init__.py:51:) -> ForeachDefinition:\n./tests/func/parsing/__init__.py:52:    return ForeachDefinition(\n./dvc/parsing/__init__.py:123:Definition = Union[\"ForeachDefinition\", \"EntryDefinition\"]\n./dvc/parsing/__init__.py:131:        return ForeachDefinition(*args, **kwargs)\n./dvc/parsing/__init__.py:161:        # we wrap the definitions into ForeachDefinition and EntryDefinition,\n./dvc/parsing/__init__.py:175:        # all of the checks for `key` not being None for `ForeachDefinition`\n./dvc/parsing/__init__.py:201:            return isinstance(definition, ForeachDefinition) and definition.has_member(\n./dvc/parsing/__init__.py:204:        return not isinstance(definition, ForeachDefinition)\n./dvc/parsing/__init__.py:209:            if isinstance(definition, ForeachDefinition):\n./dvc/parsing/__init__.py:259:            # that itself. See `ForeachDefinition.do_definition`.\n./dvc/parsing/__init__.py:315:class ForeachDefinition:\n",
  "stderr": "",
  "exit_code": 0
}

{
  "status": "ok",
  "stdout": ".......................                                                  [100%]\n23 passed in 0.85s\n",
  "stderr": "",
  "exit_code": 0
}

{
  "status": "ok",
  "stdout": " M dvc/parsing/__init__.py\ndiff --git a/dvc/parsing/__init__.py b/dvc/parsing/__init__.py\nindex 1c1e03b..6d3f47a 100644\n--- a/dvc/parsing/__init__.py\n+++ b/dvc/parsing/__init__.py\n@@ -392,7 +392,7 @@ class ForeachDefinition:\n         \"\"\"Convert sequence to Mapping with keys normalized.\"\"\"\n         iterable = self.resolved_iterable\n         if isinstance(iterable, Mapping):\n-            return iterable\n+            return {to_str(k): v for k, v in iterable.items()}\n \n         assert isinstance(iterable, Sequence)\n         if any(map(is_map_or_seq, iterable)):\n",
  "stderr": "",
  "exit_code": 0
}

{
  "status": "ok",
  "patch_size": 538,
  "files_changed": 1
}