sfdo-tooling__cumulusci-3624

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

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

{
  "status": "ok",
  "stdout": "__init__.py\nbase.py\ncommit_status.py\nmerge.py\npublish.py\npull_request.py\nrelease.py\nrelease_report.py\ntag.py\ntests\nutil.py\n",
  "stderr": "",
  "exit_code": 0
}

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

{
  "status": "ok",
  "stdout": "./cumulusci/tasks/github/merge.py:31:        \"skip_future_releases\": {\n./cumulusci/tasks/github/merge.py:52:        self.options[\"skip_future_releases\"] = process_bool_arg(\n./cumulusci/tasks/github/merge.py:53:            self.options.get(\"skip_future_releases\") or True\n./cumulusci/tasks/github/merge.py:108:        skip_future_releases = self.options[\"skip_future_releases\"]\n./cumulusci/tasks/github/merge.py:143:                if skip_future_releases and self._is_future_release_branch(\n./docs/history.md:1235:    `skip_future_releases`, which can be set to `False` to disable the\n",
  "stderr": "",
  "exit_code": 0
}

{
  "status": "ok",
  "filepath": "cumulusci/tasks/github/merge.py",
  "content": "import http.client\n\nimport github3.exceptions\nfrom github3 import GitHubError\n\nfrom cumulusci.core.exceptions import GithubApiNotFoundError\nfrom cumulusci.core.utils import process_bool_arg\nfrom cumulusci.tasks.github.base import BaseGithubTask\nfrom cumulusci.utils.git import is_release_branch\n\n\nclass MergeBranch(BaseGithubTask):\n    task_docs = \"\"\"\n    Merges the most recent commit on the current branch into other branches depending on the value of source_branch.\n\n    If source_branch is a branch that does not start with the specified branch_prefix, then the commit will be\n    merged to all branches that begin with branch_prefix and are not themselves child branches (i.e. branches don't contain '__' in their name).\n\n    If source_branch begins with branch_prefix, then the commit is merged to all child branches of source_branch.\n    \"\"\"\n    task_options = {  # TODO: should use `class Options instead`\n        \"commit\": {\n            \"description\": \"The commit to merge into feature branches.  Defaults to the current head commit.\"\n        },\n        \"source_branch\": {\n            \"description\": \"The source branch to merge from.  Defaults to project__git__default_branch.\"\n        },\n        \"branch_prefix\": {\n            \"description\": \"A list of prefixes of branches that should receive the merge.  Defaults to project__git__prefix_feature\"\n        },\n        \"skip_future_releases\": {\n            \"description\": \"If true, then exclude branches that start with the branch prefix if they are not for the lowest release number. Defaults to True.\"\n        },\n        \"update_future_releases\": {\n            \"description\": \"If true, then include release branches that are not the lowest release number even if they are not child branches. Defaults to False.\"\n        },\n    }\n\n    def _init_options(self, kwargs):\n        super()._init_options(kwargs)\n\n        if \"commit\" not in self.options:\n            self.options[\"commit\"] = self.project_config.repo_commit\n        if \"branch_prefix\" not in self.options:\n            self.options[\n                \"branch_prefix\"\n            ] = self.project_config.project__git__prefix_feature\n        if \"source_branch\" not in self.options:\n            self.options[\n                \"source_branch\"\n            ] = self.project_config.project__git__default_branch\n        self.options[\"skip_future_releases\"] = process_bool_arg(\n            self.options.get(\"skip_future_releases\") or True\n        )\n        self.options[\"update_future_releases\"] = process_bool_arg(\n            self.options.get(\"update_future_releases\") or False\n        )\n\n    def _init_task(self):\n        super()._init_task()\n        self.repo = self.get_repo()\n\n    def _run_task(self):\n        self._validate_source_branch(self.options[\"source_branch\"])\n        branches_to_merge = self._get_branches_to_merge()\n\n        for branch in branches_to_merge:\n            self._merge(\n                branch.name,\n                self.options[\"source_branch\"],\n                self.options[\"commit\"],\n            )\n\n    def _validate_source_branch(self, source_branch):\n        \"\"\"Validates that the source branch exists in the repository\"\"\"\n        try:\n            self.repo.branch(source_branch)\n        except github3.exceptions.NotFoundError:\n            message = f\"Branch {source_branch} not found\"\n            raise GithubApiNotFoundError(message)\n\n    def _get_existing_prs(self, source_branch, branch_prefix):\n        \"\"\"Returns the existing pull requests from the source branch\n        to other branches that are candidates for merging.\"\"\"\n        existing_prs = []\n        for pr in self.repo.pull_requests(state=\"open\"):\n            if pr.base.ref.startswith(branch_prefix) and pr.head.ref == source_branch:\n                existing_prs.append(pr.base.ref)\n        return existing_prs\n\n    def _get_branches_to_merge(self):\n        \"\"\"\n        If source_branch is the default branch (or a branch that doesn't start with a prefix), we\n        gather all branches with branch_prefix that are not child branches.\n        NOTE: We only include the _next_ closest release branch when automerging from main.\n        A change on main may conflict with the current contents of the lowest release branch.\n        In this case, we would like for that conflict to only need to be resolved once\n        (not once for each release branch).\n\n        If source_branch starts with branch prefix, we gather\n        all branches with branch_prefix that are direct descendents of source_branch.\n\n        If update_future_releases is True, and source_branch is a release branch\n        then we also collect all future release branches.\n        \"\"\"\n        repo_branches = list(self.repo.branches())\n        next_release = self._get_next_release(repo_branches)\n        skip_future_releases = self.options[\"skip_future_releases\"]\n        update_future_releases = self._update_future_releases(next_release)\n\n        child_branches = []\n        main_descendents = []\n        release_branches = []\n        for branch in repo_branches:\n            # check for adding future release branches\n            if update_future_releases and self._is_future_release_branch(\n                branch.name, next_release\n            ):\n                release_branches.append(branch)\n                continue\n\n            # check if we looking at the source_branch\n            if branch.name == self.options[\"source_branch\"]:\n                self.logger.debug(f\"Skipping branch {branch.name}: is source branch\")\n                continue\n\n            # check for branch prefix match\n            elif not branch.name.startswith(self.options[\"branch_prefix\"]):\n                self.logger.debug(\n                    f\"Skipping branch {branch.name}: does not match prefix '{self.options['branch_prefix']}'\"\n                )\n                continue\n\n            # check if source_branch doesn't have prefix and is not a child (e.g. main)\n            elif (\n                not self.options[\"source_branch\"].startswith(\n                    self.options[\"branch_prefix\"]\n                )\n                and \"__\" not in branch.name\n            ):\n                # only merge to the lowest numbered release branch\n                # when merging from a branch without a prefix (e.g. main)\n                if skip_future_releases and self._is_future_release_branch(\n                    branch.name, next_release\n                ):\n                    continue\n                main_descendents.append(branch)\n\n            # else, we have a branch that starts with branch_prefix\n            # check is this branch is a direct descendent",
  "start_line": 1,
  "end_line": 150,
  "total_lines": 287,
  "is_truncated": true
}

{
  "status": "ok",
  "stdout": "53:def process_bool_arg(arg: T.Union[int, str, None]):\n",
  "stderr": "",
  "exit_code": 0
}

{
  "status": "ok",
  "filepath": "cumulusci/core/utils.py",
  "content": "def process_bool_arg(arg: T.Union[int, str, None]):\n    \"\"\"Determine True/False from argument.\n\n    Similar to parts of the Salesforce API, there are a few true-ish and false-ish strings,\n        but \"True\" and \"False\" are the canonical ones.\n\n    None is accepted as \"False\" for backwards compatiblity reasons, but this usage is deprecated.\n    \"\"\"\n    if isinstance(arg, (int, bool)):\n        return bool(arg)\n    elif arg is None:\n        # backwards compatible behaviour that some tasks\n        # rely upon.\n        import traceback\n\n        warnings.warn(\"\".join(traceback.format_stack(limit=4)), DeprecationWarning)\n        warnings.warn(\n            \"Future versions of CCI will not accept 'None' as an argument to process_bool_arg\",",
  "start_line": 53,
  "end_line": 70,
  "total_lines": 364,
  "is_truncated": false
}

{
  "status": "ok",
  "stdout": "False or True: True\nprocess_bool_arg(False or True): True\nprocess_bool_arg(True or True): True\nprocess_bool_arg(None or True): True\n",
  "stderr": "/workspace/cumulusci/__init__.py:8: UserWarning: pkg_resources is deprecated as an API. See https://setuptools.pypa.io/en/latest/pkg_resources.html. The pkg_resources package is slated for removal as early as 2025-11-30. Refrain from using this package or pin to Setuptools<81.\n  __import__(\"pkg_resources\").declare_namespace(\"cumulusci\")\n",
  "exit_code": 0
}

{
  "status": "ok",
  "stdout": "cumulusci/cumulusci.yml:341:    github_automerge_main:\ncumulusci/cumulusci.yml:1168:                task: github_automerge_main\ncumulusci/cumulusci.yml:1201:                task: github_automerge_main\ncumulusci/cumulusci.yml:1228:                task: github_automerge_main\n",
  "stderr": "",
  "exit_code": 0
}

{
  "status": "ok",
  "filepath": "cumulusci/cumulusci.yml",
  "content": "    github_automerge_main:\n        description: Merges the latest commit on the main branch into all open feature branches\n        class_path: cumulusci.tasks.github.MergeBranch\n        group: GitHub\n    github_automerge_feature:\n        description: Merges the latest commit on a source branch to all child branches.\n        class_path: cumulusci.tasks.github.MergeBranch\n        options:\n            source_branch: $project_config.repo_branch\n        group: GitHub\n    github_copy_subtree:\n        description: Copies one or more subtrees from the project repository for a given release to a target repository, with the option to include release notes.\n        class_path: cumulusci.tasks.github.publish.PublishSubtree\n        group: GitHub\n    github_package_data:\n        description: Look up 2gp package dependencies for a version id recorded in a commit status.\n        class_path: cumulusci.tasks.github.commit_status.GetPackageDataFromCommitStatus\n        group: GitHub\n    github_pull_requests:\n        description: Lists open pull requests in project Github repository\n        class_path: cumulusci.tasks.github.PullRequests\n        group: GitHub\n    github_release:\n        description: Creates a Github release for a given managed package version number\n        class_path: cumulusci.tasks.github.CreateRelease\n        group: GitHub\n    gather_release_notes:\n        description: Generates release notes by getting the latest release of each repository\n        class_path: cumulusci.tasks.release_notes.task.AllGithubReleaseNotes\n        group: GitHub\n    github_release_notes:\n        description: Generates release notes by parsing pull request bodies of merged pull requests between two tags\n        class_path: cumulusci.tasks.release_notes.task.GithubReleaseNotes\n        group: GitHub\n    github_release_report:\n        description: Parses GitHub release notes to report various info\n        class_path: cumulusci.tasks.github.ReleaseReport\n        group: GitHub\n    install_managed:\n        description: Install the latest managed production release\n        class_path: cumulusci.tasks.salesforce.InstallPackageVersion\n        options:\n            version: latest\n        group: Salesforce Packages\n    install_managed_beta:\n        description: Installs the latest managed beta release\n        class_path: cumulusci.tasks.salesforce.InstallPackageVersion\n        options:\n            version: latest_beta\n        group: Salesforce Packages\n    list_communities:\n        description: Lists Communities for the current org using the Connect API.\n        class_path: cumulusci.tasks.salesforce.ListCommunities\n        group: Salesforce Communities\n    list_community_templates:\n        description: Prints the Community Templates available to the current org\n        class_path: cumulusci.tasks.salesforce.ListCommunityTemplates\n        group: Salesforce Communities\n    list_metadata_types:\n        description: Prints the metadata types in a project\n        class_path: cumulusci.tasks.util.ListMetadataTypes\n        group: Salesforce Metadata\n    meta_xml_apiversion:\n        description: Set the API version in ``*meta.xml`` files\n        class_path: cumulusci.tasks.metaxml.UpdateApi\n        group: Salesforce Metadata\n    meta_xml_dependencies:\n        description: Set the version for dependent packages\n        class_path: cumulusci.tasks.metaxml.UpdateDependencies\n        group: Salesforce Metadata\n    metadeploy_publish:\n        description: Publish a release to the MetaDeploy web installer\n        class_path: cumulusci.tasks.metadeploy.Publish\n        group: Release Operations\n    org_settings:\n        description: Apply org settings from a scratch org definition file or dict\n        class_path: cumulusci.tasks.salesforce.org_settings.DeployOrgSettings\n        group: Salesforce DX\n    promote_package_version:\n        description: Promote a 2gp package so that it can be installed in a production org\n        class_path: cumulusci.tasks.salesforce.promote_package_version.PromotePackageVersion\n        group: Release Operations\n    publish_community:\n        description: Publishes a Community in the target org using the Connect API\n        class_path: cumulusci.tasks.salesforce.PublishCommunity\n        group: Salesforce Communities\n    push_all:\n        description: Schedules a push upgrade of a package version to all subscribers\n        class_path: cumulusci.tasks.push.tasks.SchedulePushOrgQuery\n        group: Push Upgrades\n    push_list:\n        description: Schedules a push upgrade of a package version to all orgs listed in the specified file\n        class_path: cumulusci.tasks.push.tasks.SchedulePushOrgList\n        group: Push Upgrades\n    push_qa:\n        description: Schedules a push upgrade of a package version to all orgs listed in push/orgs_qa.txt\n        class_path: cumulusci.tasks.push.tasks.SchedulePushOrgList\n        options:\n            orgs: push/orgs_qa.txt\n        group: Push Upgrades\n    push_sandbox:\n        description: Schedules a push upgrade of a package version to sandbox orgs\n        class_path: cumulusci.tasks.push.tasks.SchedulePushOrgQuery\n        options:\n            subscriber_where: \"OrgType = 'Sandbox'\"\n        group: Push Upgrades\n    push_trial:\n        description: Schedules a push upgrade of a package version to Trialforce Template orgs listed in push/orgs_trial.txt\n        class_path: cumulusci.tasks.push.tasks.SchedulePushOrgList\n        options:\n            orgs: push/orgs_trial.txt\n        group: Push Upgrades\n    push_failure_report:\n        description: Produce a CSV report of the failed and otherwise anomalous push jobs.\n        class_path: cumulusci.tasks.push.pushfails.ReportPushFailures\n        options:\n            ignore_errors:\n                - \"Salesforce Subscription Expired\"\n                - \"Package Uninstalled\"\n        group: Push Upgrades\n    query:\n        description: Queries the connected org\n        class_path: cumulusci.tasks.salesforce.SOQLQuery\n        group: Salesforce Bulk API\n    retrieve_packaged:\n        description: Retrieves the packaged metadata from the org\n        class_path: cumulusci.tasks.salesforce.RetrievePackaged\n        options:\n            path: packaged\n        group: Salesforce Metadata\n    retrieve_src:\n        description: Retrieves the packaged metadata into the src directory\n        class_path: cumulusci.tasks.salesforce.RetrievePackaged\n        options:\n            path: src\n        group: Salesforce Metadata\n    retrieve_unpackaged:\n        description: Retrieve the contents of a package.xml file.\n        class_path: cumulusci.tasks.salesforce.RetrieveUnpackaged\n    list_changes:\n        description: List the changes from a scratch org\n        class_path: cumulusci.tasks.salesforce.sourcetracking.ListChanges\n        group: Salesforce Metadata\n    retrieve_changes:\n        description: Retrieve changed components from a scratch org\n        class_path: cumulusci.tasks.salesforce.sourcetracking.RetrieveChanges\n        group: Salesforce Metadata\n    retrieve_qa_config:\n        description: Retrieves the current changes in the scratch org into unpackaged/config/qa\n        class_path: cumulusci.tasks.salesforce.sourcetracking.RetrieveChanges",
  "start_line": 341,
  "end_line": 490,
  "total_lines": 1528,
  "is_truncated": true
}

{
  "status": "ok",
  "filepath": "cumulusci/tasks/github/merge.py",
  "occurrences": 1,
  "strategy": "exact",
  "diff": "--- a/cumulusci/tasks/github/merge.py\n+++ b/cumulusci/tasks/github/merge.py\n@@ -50,10 +50,10 @@\n                 \"source_branch\"\n             ] = self.project_config.project__git__default_branch\n         self.options[\"skip_future_releases\"] = process_bool_arg(\n-            self.options.get(\"skip_future_releases\") or True\n+            self.options.get(\"skip_future_releases\", True)\n         )\n         self.options[\"update_future_releases\"] = process_bool_arg(\n-            self.options.get(\"update_future_releases\") or False\n+            self.options.get(\"update_future_releases\", False)\n         )\n \n     def _init_task(self):\n",
  "is_truncated": false
}

{
  "status": "ok",
  "stdout": "cumulusci/tasks/github/tests/test_merge.py:10:from cumulusci.tasks.github import MergeBranch\ncumulusci/tasks/github/tests/test_merge.py:15:class TestMergeBranch(MockUtilBase):\ncumulusci/tasks/github/tests/test_merge.py:43:        return MergeBranch(\ncumulusci/tasks/github/tests/test_merge.py:118:        of MergeBranch with the given branch_names.\ncumulusci/tasks/github/tests/test_merge.py:219:                (\"INFO\", \"Beginning task: MergeBranch\"),\ncumulusci/tasks/github/tests/test_merge.py:918:        (\"INFO\", \"Beginning task: MergeBranch\"),\n",
  "stderr": "",
  "exit_code": 0
}

{
  "status": "ok",
  "filepath": "cumulusci/tasks/github/tests/test_merge.py",
  "content": "import http.client\n\nimport github3\nimport pytest\nimport responses\nfrom testfixtures import LogCapture\n\nfrom cumulusci.core.config import ServiceConfig, TaskConfig\nfrom cumulusci.core.exceptions import GithubApiNotFoundError\nfrom cumulusci.tasks.github import MergeBranch\nfrom cumulusci.tasks.release_notes.tests.utils import MockUtilBase\nfrom cumulusci.tests.util import DummyOrgConfig, create_project_config\n\n\nclass TestMergeBranch(MockUtilBase):\n    def setup_method(self):\n\n        # Set up the mock values\n        self.repo = \"TestRepo\"\n        self.owner = \"TestOwner\"\n        self.repo_api_url = f\"https://api.github.com/repos/{self.owner}/{self.repo}\"\n        self.branch = \"main\"\n\n        # Create the project config\n        self.project_config = create_project_config(self.repo, self.owner)\n        self.project_config.config[\"project\"][\"git\"][\"default_branch\"] = self.branch\n        self.project_config.keychain.set_service(\n            \"github\",\n            \"test_alias\",\n            ServiceConfig(\n                {\n                    \"username\": \"TestUser\",\n                    \"token\": \"TestPass\",\n                    \"email\": \"testuser@testdomain.com\",\n                }\n            ),\n        )\n\n    def _create_task(self, task_config=None):\n        if not task_config:\n            task_config = {}\n\n        return MergeBranch(\n            project_config=self.project_config,\n            task_config=TaskConfig(task_config),\n            org_config=DummyOrgConfig(),\n        )\n\n    def _mock_repo(self):\n        api_url = self.repo_api_url\n\n        expected_response = self._get_expected_repo(owner=self.owner, name=self.repo)\n        responses.add(method=responses.GET, url=api_url, json=expected_response)\n        return expected_response\n\n    def _mock_branch(self, branch, expected_response=None):\n        api_url = f\"{self.repo_api_url}/branches/{branch}\"\n        if not expected_response:\n            expected_response = self._get_expected_branch(branch)\n        responses.add(method=responses.GET, url=api_url, json=expected_response)\n\n    def _mock_branches(self, branches=None):\n        api_url = f\"{self.repo_api_url}/branches\"\n        if branches:\n            expected_response = branches\n        else:\n            expected_response = []\n\n        responses.add(method=responses.GET, url=api_url, json=expected_response)\n        return expected_response\n\n    def _mock_branch_does_not_exist(self, branch):\n        api_url = f\"{self.repo_api_url}/branches/{branch}\"\n        expected_response = self._get_expected_not_found()\n        responses.add(\n            method=responses.GET,\n            url=api_url,\n            status=http.client.NOT_FOUND,  # 404\n            json=expected_response,\n        )\n\n    def _mock_merge(self, status=http.client.CREATED):\n        api_url = f\"{self.repo_api_url}/merges\"\n        expected_response = self._get_expected_merge(status == http.client.CONFLICT)\n\n        responses.add(\n            method=responses.POST, url=api_url, json=expected_response, status=status\n        )\n        return expected_response\n\n    def _mock_pull_create(self, pull_id, issue_id, status=None):\n        api_url = f\"{self.repo_api_url}/pulls\"\n        expected_response = self._get_expected_pull_request(pull_id, issue_id)\n\n        responses.add(\n            method=responses.POST,\n            url=api_url,\n            json=expected_response,\n            status=status or http.client.CREATED,  # 201\n        )\n\n    def _mock_compare(self, base, head, files=None):\n        api_url = f\"{self.repo_api_url}/compare/{base}...{head}\"\n        expected_response = self._get_expected_compare(base, head, files)\n\n        responses.add(method=responses.GET, url=api_url, json=expected_response)\n\n    def _get_log_lines(self, log):\n        log_lines = []\n        for event in log.records:\n            if event.name != \"cumulusci.core.tasks\":\n                continue\n            log_lines.append((event.levelname, event.getMessage()))\n        return log_lines\n\n    def _setup_mocks(self, branch_names, merges=True, compare_diff=True):\n        \"\"\"Setup all mocks needed for an integration test\n        of MergeBranch with the given branch_names.\n        source_branch should be at index 0\n        \"\"\"\n        # Create response for repo endpoint\n        self._mock_repo()\n        # Create endpoint for repo/pulls...\n        self.mock_pulls()\n\n        # Create response for source branch endpoint\n        self._mock_branch(branch_names[0])\n\n        branch_response_bodies = []\n        for name in branch_names:\n            branch_response_bodies.append(self._get_expected_branch(name))\n\n        # Create response for repo/branches endpoint\n        branches = self._mock_branches(branch_response_bodies)\n\n        if merges:\n            # Create endpoint for repo/merges endpoint\n            merges = [self._mock_merge()]\n        # Create endpoints for repo/compare/{base}...{head}\n        for branch in branches[1:]:\n            files = [{\"filename\": \"text.txt\"}] if compare_diff else []\n            self._mock_compare(\n                base=branch[\"name\"],\n                head=self.project_config.repo_commit,\n                files=files,\n            )\n\n    @responses.activate\n    def test_branch_does_not_exist(self):\n        self._mock_repo()",
  "start_line": 1,
  "end_line": 150,
  "total_lines": 920,
  "is_truncated": true
}

{
  "status": "ok",
  "stdout": "All option tests passed!\n",
  "stderr": "/workspace/cumulusci/__init__.py:8: UserWarning: pkg_resources is deprecated as an API. See https://setuptools.pypa.io/en/latest/pkg_resources.html. The pkg_resources package is slated for removal as early as 2025-11-30. Refrain from using this package or pin to Setuptools<81.\n  __import__(\"pkg_resources\").declare_namespace(\"cumulusci\")\n",
  "exit_code": 0
}

{
  "status": "ok",
  "stdout": ".......................                                                  [100%]\n23 passed in 0.41s\n",
  "stderr": "/CumulusCI/cumulusci/__init__.py:8: UserWarning: pkg_resources is deprecated as an API. See https://setuptools.pypa.io/en/latest/pkg_resources.html. The pkg_resources package is slated for removal as early as 2025-11-30. Refrain from using this package or pin to Setuptools<81.\n  __import__(\"pkg_resources\").declare_namespace(\"cumulusci\")\n",
  "exit_code": 0
}

{
  "status": "ok",
  "filepath": "cumulusci/tasks/github/merge.py",
  "content": "import http.client\n\nimport github3.exceptions\nfrom github3 import GitHubError\n\nfrom cumulusci.core.exceptions import GithubApiNotFoundError\nfrom cumulusci.core.utils import process_bool_arg\nfrom cumulusci.tasks.github.base import BaseGithubTask\nfrom cumulusci.utils.git import is_release_branch\n\n\nclass MergeBranch(BaseGithubTask):\n    task_docs = \"\"\"\n    Merges the most recent commit on the current branch into other branches depending on the value of source_branch.\n\n    If source_branch is a branch that does not start with the specified branch_prefix, then the commit will be\n    merged to all branches that begin with branch_prefix and are not themselves child branches (i.e. branches don't contain '__' in their name).\n\n    If source_branch begins with branch_prefix, then the commit is merged to all child branches of source_branch.\n    \"\"\"\n    task_options = {  # TODO: should use `class Options instead`\n        \"commit\": {\n            \"description\": \"The commit to merge into feature branches.  Defaults to the current head commit.\"\n        },\n        \"source_branch\": {\n            \"description\": \"The source branch to merge from.  Defaults to project__git__default_branch.\"\n        },\n        \"branch_prefix\": {\n            \"description\": \"A list of prefixes of branches that should receive the merge.  Defaults to project__git__prefix_feature\"\n        },\n        \"skip_future_releases\": {\n            \"description\": \"If true, then exclude branches that start with the branch prefix if they are not for the lowest release number. Defaults to True.\"\n        },\n        \"update_future_releases\": {\n            \"description\": \"If true, then include release branches that are not the lowest release number even if they are not child branches. Defaults to False.\"\n        },\n    }\n\n    def _init_options(self, kwargs):\n        super()._init_options(kwargs)\n\n        if \"commit\" not in self.options:\n            self.options[\"commit\"] = self.project_config.repo_commit\n        if \"branch_prefix\" not in self.options:\n            self.options[\n                \"branch_prefix\"\n            ] = self.project_config.project__git__prefix_feature\n        if \"source_branch\" not in self.options:\n            self.options[\n                \"source_branch\"\n            ] = self.project_config.project__git__default_branch\n        self.options[\"skip_future_releases\"] = process_bool_arg(\n            self.options.get(\"skip_future_releases\", True)\n        )\n        self.options[\"update_future_releases\"] = process_bool_arg(\n            self.options.get(\"update_future_releases\", False)\n        )\n\n    def _init_task(self):\n        super()._init_task()\n        self.repo = self.get_repo()\n\n    def _run_task(self):\n        self._validate_source_branch(self.options[\"source_branch\"])\n        branches_to_merge = self._get_branches_to_merge()\n\n        for branch in branches_to_merge:\n            self._merge(\n                branch.name,\n                self.options[\"source_branch\"],\n                self.options[\"commit\"],\n            )\n\n    def _validate_source_branch(self, source_branch):\n        \"\"\"Validates that the source branch exists in the repository\"\"\"\n        try:\n            self.repo.branch(source_branch)\n        except github3.exceptions.NotFoundError:\n            message = f\"Branch {source_branch} not found\"\n            raise GithubApiNotFoundError(message)\n\n    def _get_existing_prs(self, source_branch, branch_prefix):\n        \"\"\"Returns the existing pull requests from the source branch\n        to other branches that are candidates for merging.\"\"\"\n        existing_prs = []\n        for pr in self.repo.pull_requests(state=\"open\"):\n            if pr.base.ref.startswith(branch_prefix) and pr.head.ref == source_branch:\n                existing_prs.append(pr.base.ref)\n        return existing_prs\n\n    def _get_branches_to_merge(self):\n        \"\"\"\n        If source_branch is the default branch (or a branch that doesn't start with a prefix), we\n        gather all branches with branch_prefix that are not child branches.\n        NOTE: We only include the _next_ closest release branch when automerging from main.\n        A change on main may conflict with the current contents of the lowest release branch.\n        In this case, we would like for that conflict to only need to be resolved once\n        (not once for each release branch).\n\n        If source_branch starts with branch prefix, we gather\n        all branches with branch_prefix that are direct descendents of source_branch.\n\n        If update_future_releases is True, and source_branch is a release branch\n        then we also collect all future release branches.\n        \"\"\"\n        repo_branches = list(self.repo.branches())\n        next_release = self._get_next_release(repo_branches)\n        skip_future_releases = self.options[\"skip_future_releases\"]\n        update_future_releases = self._update_future_releases(next_release)\n\n        child_branches = []\n        main_descendents = []\n        release_branches = []\n        for branch in repo_branches:\n            # check for adding future release branches\n            if update_future_releases and self._is_future_release_branch(\n                branch.name, next_release\n            ):\n                release_branches.append(branch)\n                continue\n\n            # check if we looking at the source_branch\n            if branch.name == self.options[\"source_branch\"]:\n                self.logger.debug(f\"Skipping branch {branch.name}: is source branch\")\n                continue\n\n            # check for branch prefix match\n            elif not branch.name.startswith(self.options[\"branch_prefix\"]):\n                self.logger.debug(\n                    f\"Skipping branch {branch.name}: does not match prefix '{self.options['branch_prefix']}'\"\n                )\n                continue\n\n            # check if source_branch doesn't have prefix and is not a child (e.g. main)\n            elif (\n                not self.options[\"source_branch\"].startswith(\n                    self.options[\"branch_prefix\"]\n                )\n                and \"__\" not in branch.name\n            ):\n                # only merge to the lowest numbered release branch\n                # when merging from a branch without a prefix (e.g. main)\n                if skip_future_releases and self._is_future_release_branch(\n                    branch.name, next_release\n                ):\n                    continue\n                main_descendents.append(branch)\n\n            # else, we have a branch that starts with branch_prefix\n            # check is this branch is a direct descendent",
  "start_line": 1,
  "end_line": 150,
  "total_lines": 287,
  "is_truncated": true
}

{
  "status": "ok",
  "stdout": "cumulusci/tasks/github/base.py:5:class BaseGithubTask(BaseTask):\n",
  "stderr": "",
  "exit_code": 0
}

{
  "status": "ok",
  "filepath": "cumulusci/tasks/github/base.py",
  "content": "from cumulusci.core.github import get_github_api_for_repo\nfrom cumulusci.core.tasks import BaseTask\n\n\nclass BaseGithubTask(BaseTask):\n    def _init_task(self):\n        super()._init_task()\n        self.github_config = self.project_config.keychain.get_service(\"github\")\n        self.github = get_github_api_for_repo(\n            self.project_config.keychain, self.project_config.repo_url\n        )\n\n    def get_repo(self):\n        return self.github.repository(\n            self.project_config.repo_owner, self.project_config.repo_name\n        )",
  "start_line": 1,
  "end_line": 16,
  "total_lines": 16,
  "is_truncated": false
}

{
  "status": "error",
  "error_type": "CommandError",
  "error_message": "grep: cumulusci/core/tasks/: No such file or directory\n",
  "details": {
    "stdout": "",
    "stderr": "grep: cumulusci/core/tasks/: No such file or directory\n",
    "exit_code": 2
  },
  "budget_warning": "Only 10 tool call(s) remaining (20/30 used). Finalize your edits and call submit_patch soon."
}

{
  "status": "ok",
  "stdout": "cumulusci/core/config/base_task_flow_config.py:28:class BaseTaskFlowConfig(BaseConfig):\ncumulusci/core/tasks.py:3:Subclass BaseTask or a descendant to define custom task logic\ncumulusci/core/tasks.py:50:class BaseTask:\ncumulusci/core/tasks.py:53:    Subclass BaseTask and provide a `_run_task()` method with your\n",
  "stderr": "",
  "exit_code": 0,
  "budget_warning": "Only 9 tool call(s) remaining (21/30 used). Finalize your edits and call submit_patch soon."
}

{
  "status": "ok",
  "filepath": "cumulusci/core/tasks.py",
  "content": "\"\"\" Tasks are the basic unit of execution in CumulusCI.\n\nSubclass BaseTask or a descendant to define custom task logic\n\"\"\"\nimport contextlib\nimport logging\nimport os\nimport re\nimport threading\nimport time\nfrom contextlib import nullcontext\nfrom typing import Any, Callable, Dict, List, Optional, Type, Union\n\nfrom pydantic.error_wrappers import ValidationError\n\nfrom cumulusci import __version__\nfrom cumulusci.core.config import TaskConfig\nfrom cumulusci.core.config.org_config import OrgConfig\nfrom cumulusci.core.config.project_config import BaseProjectConfig\nfrom cumulusci.core.debug import DebugMode, get_debug_mode\nfrom cumulusci.core.exceptions import (\n    ServiceNotConfigured,\n    ServiceNotValid,\n    TaskOptionsError,\n    TaskRequiresSalesforceOrg,\n)\nfrom cumulusci.core.flowrunner import FlowCoordinator, StepSpec, StepVersion\nfrom cumulusci.utils import cd\nfrom cumulusci.utils.logging import redirect_output_to_logger\nfrom cumulusci.utils.metaprogramming import classproperty\nfrom cumulusci.utils.options import CCIOptions\n\nCURRENT_TASK = threading.local()\n\nPROJECT_CONFIG_RE = re.compile(r\"\\$project_config.(\\w+)\")\nCAPTURE_TASK_OUTPUT = os.environ.get(\"CAPTURE_TASK_OUTPUT\")\n\n\n@contextlib.contextmanager\ndef stacked_task(task):\n    if not hasattr(CURRENT_TASK, \"stack\"):\n        CURRENT_TASK.stack = []\n    CURRENT_TASK.stack.append(task)\n    try:\n        yield\n    finally:\n        CURRENT_TASK.stack.pop()\n\n\nclass BaseTask:\n    \"\"\"BaseTask provides the core execution logic for a Task\n\n    Subclass BaseTask and provide a `_run_task()` method with your\n    code.\n    \"\"\"\n\n    task_docs: str = \"\"\n    Options: Optional[Type[CCIOptions]] = None\n    salesforce_task: bool = False  # Does this task require a salesforce org?\n    name: Optional[str]\n    stepnum: Optional[StepVersion]\n    result: Any\n    return_values: dict\n    debug_mode: DebugMode\n    logger: logging.Logger\n    options: dict\n\n    poll_complete: bool\n    poll_count: int\n    poll_interval_level: int\n    poll_interval_s: int\n\n    def __init__(\n        self,\n        project_config: BaseProjectConfig,\n        task_config: TaskConfig,\n        org_config: Optional[OrgConfig] = None,\n        flow: Optional[FlowCoordinator] = None,\n        name: Optional[str] = None,\n        stepnum: Optional[StepVersion] = None,\n        logger: Optional[logging.Logger] = None,\n        **kwargs,\n    ):\n        self.project_config = project_config\n        self.task_config = task_config\n        self.org_config = org_config\n\n        self._reset_poll()\n\n        # dict of return_values that can be used by task callers\n        self.return_values = {}\n        # simple result object for introspection, often a return_code\n        self.result = None\n        # the flow for this task execution\n        self.flow = flow\n        # the task's name in the flow\n        self.name = name\n        # the task's stepnumber in the flow\n        self.stepnum = stepnum\n\n        self.debug_mode = get_debug_mode()\n        if logger:\n            self.logger = logger\n        else:\n            self._init_logger()\n\n        self._init_options(kwargs)\n        self._validate_options()\n\n    def _init_logger(self):\n        \"\"\"Initializes self.logger\"\"\"\n        if self.flow:\n            self.logger = self.flow.logger.getChild(self.__class__.__name__)\n        else:\n            self.logger = logging.getLogger(__name__)\n\n    @classproperty\n    def task_options(cls):  # type: ignore  -- doesn't like the signature override below\n        \"Convert Options dict into old fashioned task_options syntax\"\n        if cls.Options:\n            return cls.Options.as_task_options()\n        else:\n            return {}\n\n    task_options: Union[classproperty, Dict]\n\n    def _init_options(self, kwargs):\n        \"\"\"Initializes self.options\"\"\"\n        if self.task_config.options is None:\n            self.options = {}\n        else:\n            self.options = self.task_config.options.copy()\n\n        if kwargs:\n            self.options.update(kwargs)\n\n        # Handle dynamic lookup of project_config values via $project_config.attr\n        for option, value in self.options.items():\n            if isinstance(value, str):\n                value = PROJECT_CONFIG_RE.sub(\n                    lambda match: str(self.project_config.lookup(match.group(1), None)),\n                    value,\n                )\n                self.options[option] = value\n\n        if self.Options:\n            try:\n                specials = [\"debug_before\", \"debug_after\", \"no_prompt\"]\n                options_without_specials = {\n                    opt: val for opt, val in self.options.items() if opt not in specials",
  "start_line": 1,
  "end_line": 150,
  "total_lines": 390,
  "is_truncated": true,
  "budget_warning": "Only 8 tool call(s) remaining (22/30 used). Finalize your edits and call submit_patch soon."
}

{
  "status": "ok",
  "stdout": "53:def process_bool_arg(arg: T.Union[int, str, None]):\n",
  "stderr": "",
  "exit_code": 0,
  "budget_warning": "Only 7 tool call(s) remaining (23/30 used). Finalize your edits and call submit_patch soon."
}

{
  "status": "ok",
  "filepath": "cumulusci/core/utils.py",
  "content": "    return datetime(t[0], t[1], t[2], t[3], t[4], t[5], t[6], pytz.UTC)\n\n\ndef process_bool_arg(arg: T.Union[int, str, None]):\n    \"\"\"Determine True/False from argument.\n\n    Similar to parts of the Salesforce API, there are a few true-ish and false-ish strings,\n        but \"True\" and \"False\" are the canonical ones.\n\n    None is accepted as \"False\" for backwards compatiblity reasons, but this usage is deprecated.\n    \"\"\"\n    if isinstance(arg, (int, bool)):\n        return bool(arg)\n    elif arg is None:\n        # backwards compatible behaviour that some tasks\n        # rely upon.\n        import traceback\n\n        warnings.warn(\"\".join(traceback.format_stack(limit=4)), DeprecationWarning)\n        warnings.warn(\n            \"Future versions of CCI will not accept 'None' as an argument to process_bool_arg\",",
  "start_line": 50,
  "end_line": 70,
  "total_lines": 364,
  "is_truncated": false,
  "budget_warning": "Only 6 tool call(s) remaining (24/30 used). Finalize your edits and call submit_patch soon."
}

{
  "status": "ok",
  "stdout": "True: True False: False None: False\n",
  "stderr": "/workspace/cumulusci/__init__.py:8: UserWarning: pkg_resources is deprecated as an API. See https://setuptools.pypa.io/en/latest/pkg_resources.html. The pkg_resources package is slated for removal as early as 2025-11-30. Refrain from using this package or pin to Setuptools<81.\n  __import__(\"pkg_resources\").declare_namespace(\"cumulusci\")\n",
  "exit_code": 0,
  "budget_warning": "Only 5 tool call(s) remaining (25/30 used). Finalize your edits and call submit_patch soon."
}