Merge branch 'staging' into feat--silent-aiohttp.ClientOSError

Author: basfroman

.circleci/config.yml

@@ -39,7 +39,7 @@ jobs:
             python -m venv .venv
             . .venv/bin/activate
             python -m pip install --upgrade uv
-            uv pip install ruff -c requirements/dev.txt
+            uv pip install ruff==0.11.5
 
       - save_cache:
           name: Save cached ruff venv
@@ -68,9 +68,7 @@ jobs:
           name: Install dependencies and Check compatibility
           command: |
             if [ "$REQUIREMENTS_CHANGED" == "true" ]; then
-              sudo apt-get update
-              sudo apt-get install -y jq curl
-              ./scripts/check_compatibility.sh << parameters.python_version >>
+              python -m pip install ".[dev,cli]" --dry-run --python-version << parameters.python_version >> --no-deps
             else
               echo "Skipping compatibility checks..."
             fi
@@ -87,31 +85,19 @@ jobs:
     steps:
       - checkout
 
-      - restore_cache:
-          name: Restore cached venv
-          keys:
-            - v2-pypi-py<< parameters.python-version >>-{{ checksum "requirements/prod.txt" }}+{{ checksum "requirements/dev.txt" }}
-            - v2-pypi-py<< parameters.python-version >>
-
       - run:
           name: Update & Activate venv
           command: |
             python -m venv .venv
             . .venv/bin/activate
             python -m pip install --upgrade uv
-            uv sync --all-extras --dev
-
-      - save_cache:
-          name: Save cached venv
-          paths:
-            - "venv/"
-          key: v2-pypi-py<< parameters.python-version >>-{{ checksum "requirements/prod.txt" }}+{{ checksum "requirements/dev.txt" }}
+            uv sync --extra dev --dev
 
       - run:
           name: Install Bittensor
           command: |
             . .venv/bin/activate
-            uv sync --all-extras --dev
+            uv sync --extra dev --dev
 
       - run:
           name: Instantiate Mock Wallet
@@ -178,32 +164,20 @@ jobs:
     steps:
       - checkout
 
-      - restore_cache:
-          name: Restore cached venv
-          keys:
-            - v2-pypi-py<< parameters.python-version >>-{{ checksum "requirements/prod.txt" }}+{{ checksum "requirements/dev.txt" }}
-            - v2-pypi-py<< parameters.python-version >>
-
       - run:
           name: Update & Activate venv
           command: |
             python -m venv .venv
             . .venv/bin/activate
             python -m pip install --upgrade uv
-            uv sync --all-extras --dev
+            uv sync --extra dev --dev
             uv pip install flake8
 
-      - save_cache:
-          name: Save cached venv
-          paths:
-            - "env/"
-          key: v2-pypi-py<< parameters.python-version >>-{{ checksum "requirements/prod.txt" }}+{{ checksum "requirements/dev.txt" }}
-
       - run:
           name: Install Bittensor
           command: |
             . .venv/bin/activate
-            uv sync --all-extras --dev
+            uv sync --extra dev --dev
 
       - run:
           name: Lint with flake8
@@ -235,18 +209,6 @@ jobs:
             uv pip install --upgrade coveralls
             coveralls --finish --rcfile .coveragerc || echo "Failed to upload coverage"
 
-  check-version-updated:
-    docker:
-      - image: cimg/python:3.10
-    steps:
-      - checkout
-
-      - run:
-          name: Version is updated
-          command: |
-            [[ $(git diff-tree --no-commit-id --name-only -r HEAD..master | grep bittensor/__init__.py | wc -l) == 1 ]] && echo "bittensor/__init__.py has changed"
-            [[ $(git diff-tree --no-commit-id --name-only -r HEAD..master | grep VERSION | wc -l) == 1 ]] && echo "VERSION has changed"
-
   check-changelog-updated:
     docker:
       - image: cimg/python:3.10
@@ -323,11 +285,6 @@ workflows:
 
   release-branches-requirements:
     jobs:
-      - check-version-updated:
-          filters:
-            branches:
-              only:
-                - /^(release|hotfix)/.*/
       - check-changelog-updated:
           filters:
             branches:

.github/dependabot.yml

@@ -1,8 +1,7 @@
 version: 2
 updates:
   - package-ecosystem: "pip"
-    directory: ""
-    file: "requirements/prod.txt"
+    directory: "/"
     schedule:
       interval: "daily"
     open-pull-requests-limit: 0  # Only security updates will be opened as PRs

.github/workflows/e2e-subtensor-tests.yaml

@@ -41,7 +41,7 @@ jobs:
           test_files=$(find tests/e2e_tests -name "test*.py" | jq -R -s -c 'split("\n") | map(select(. != ""))')
           # keep it here for future debug
           # test_files=$(find tests/e2e_tests -type f -name "test*.py" | grep -E 'test_(incentive|commit_weights|set_weights)\.py$' | jq -R -s -c 'split("\n") | map(select(. != ""))')
-          echo "::set-output name=test-files::$test_files"
+          echo "test-files=$test_files" >> "$GITHUB_OUTPUT"
         shell: bash
 
   pull-docker-image:
@@ -91,7 +91,7 @@ jobs:
         uses: astral-sh/setup-uv@v4
 
       - name: install dependencies
-        run: uv sync --all-extras --dev
+        run: uv sync --extra dev --dev
 
       - name: Download Cached Docker Image
         uses: actions/download-artifact@v4
@@ -101,5 +101,26 @@ jobs:
       - name: Load Docker Image
         run: docker load -i subtensor-localnet.tar
 
-      - name: Run tests
-        run: uv run pytest ${{ matrix.test-file }} -s
+#      - name: Run tests
+#        run: uv run pytest ${{ matrix.test-file }} -s
+
+      - name: Run tests with retry
+        run: |
+          set +e
+          for i in 1 2; do
+            echo "🔁 Attempt $i: Running tests"
+            uv run pytest ${{ matrix.test-file }} -s
+            status=$?
+            if [ $status -eq 0 ]; then
+              echo "✅ Tests passed on attempt $i"
+              break
+            else
+              echo "❌ Tests failed on attempt $i"
+              if [ $i -eq 2 ]; then
+                echo "Tests failed after 2 attempts"
+                exit 1
+              fi
+              echo "Retrying..."
+              sleep 5
+            fi
+          done

CHANGELOG.md

@@ -1,5 +1,24 @@
 # Changelog
 
+## 9.3.1a1 /2025-04-14
+
+## What's Changed
+* Release/9.3.0 by @ibraheem-abe in https://github.com/opentensor/bittensor/pull/2805
+* Fix for flaky behavior of `test_incentive`, `test_commit_weights` and `test_set_weights`  by @basfroman in https://github.com/opentensor/bittensor/pull/2795
+* Add `get_next_epoch_start_block` method to Async/Subtensor by @basfroman in https://github.com/opentensor/bittensor/pull/2808
+* Adds compatibility for torch 2.6.0+ by @thewhaleking in https://github.com/opentensor/bittensor/pull/2811
+* f Update CONTRIBUTING.md by @Hack666r in https://github.com/opentensor/bittensor/pull/2813
+* docs: replaced discord link with documentation by @sashaphmn in https://github.com/opentensor/bittensor/pull/2809
+* sometimes it's still flaky because the chain returns data with time offset by @basfroman in https://github.com/opentensor/bittensor/pull/2816
+* Remove requirements directory by @thewhaleking in https://github.com/opentensor/bittensor/pull/2812
+* version in one place by @thewhaleking in https://github.com/opentensor/bittensor/pull/2806
+* Update CONTRIBUTING hyperlinks by @thewhaleking in https://github.com/opentensor/bittensor/pull/2820
+
+## New Contributors
+* @Hack666r made their first contribution in https://github.com/opentensor/bittensor/pull/2813
+
+**Full Changelog**: https://github.com/opentensor/bittensor/compare/v9.3.0...v9.3.1a1
+
 ## 9.3.0 /2025-04-09
 
 ## What's Changed

Makefile

@@ -21,6 +21,3 @@ install:
 
 install-dev:
 	python3 -m pip install '.[dev]'
-
-install-cubit:
-	python3 -m pip install '.[cubit]'

README.md

@@ -10,7 +10,7 @@
 
 ## Internet-scale Neural Networks <!-- omit in toc -->
 
-[Discord](https://discord.gg/qasY3HA9F9) • [Network](https://taostats.io/) • [Research](https://bittensor.com/whitepaper)
+[Discord](https://discord.gg/qasY3HA9F9) • [Network](https://taostats.io/) • [Research](https://bittensor.com/whitepaper) • [Documentation](https://docs.bittensor.com)
 
 </div>
 

VERSION

@@ -57,6 +57,7 @@
     publish_metadata,
     get_metadata,
 )
+from bittensor.core.extrinsics.asyncex.start_call import start_call_extrinsic
 from bittensor.core.extrinsics.asyncex.serving import serve_axon_extrinsic
 from bittensor.core.extrinsics.asyncex.staking import (
     add_stake_extrinsic,
@@ -752,6 +753,7 @@ async def does_hotkey_exist(
         return_val = (
             False
             if result is None
+            # not the default key (0x0)
             else result != "5C4hrfjw9DjXZTzV3MwzrrAr9P1MJhSrvWGWqi1eSuyUpnhM"
         )
         return return_val
@@ -3004,7 +3006,7 @@ async def wait_for_block(self, block: Optional[int] = None):
 
         async def handler(block_data: dict):
             logging.debug(
-                f'reached block {block_data["header"]["number"]}. Waiting for block {target_block}'
+                f"reached block {block_data['header']['number']}. Waiting for block {target_block}"
             )
             if block_data["header"]["number"] >= target_block:
                 return True
@@ -3181,7 +3183,7 @@ async def sign_and_send_extrinsic(
                 return True, ""
 
             if raise_error:
-                raise ChainError.from_error(response.error_message)
+                raise ChainError.from_error(await response.error_message)
 
             return False, format_error_message(await response.error_message)
 
@@ -3986,6 +3988,36 @@ async def serve_axon(
             certificate=certificate,
         )
 
+    async def start_call(
+        self,
+        wallet: "Wallet",
+        netuid: int,
+        wait_for_inclusion: bool = True,
+        wait_for_finalization: bool = False,
+    ) -> tuple[bool, str]:
+        """
+        Submits a start_call extrinsic to the blockchain, to trigger the start call process for a subnet (used to start a
+        new subnet's emission mechanism).
+
+        Args:
+            wallet (Wallet): The wallet used to sign the extrinsic (must be unlocked).
+            netuid (int): The UID of the target subnet for which the call is being initiated.
+            wait_for_inclusion (bool, optional): Whether to wait for the extrinsic to be included in a block. Defaults to True.
+            wait_for_finalization (bool, optional): Whether to wait for finalization of the extrinsic. Defaults to False.
+
+        Returns:
+            Tuple[bool, str]:
+                - True and a success message if the extrinsic is successfully submitted or processed.
+                - False and an error message if the submission fails or the wallet cannot be unlocked.
+        """
+        return await start_call_extrinsic(
+            subtensor=self,
+            wallet=wallet,
+            netuid=netuid,
+            wait_for_inclusion=wait_for_inclusion,
+            wait_for_finalization=wait_for_finalization,
+        )
+
     async def swap_stake(
         self,
         wallet: "Wallet",

bittensor/core/async_subtensor.py

@@ -504,9 +504,9 @@ def verify_custom(synapse: MyCustomSynapse):
             )
 
         param_class = first_param.annotation
-        assert issubclass(
-            param_class, Synapse
-        ), "The first argument of forward_fn must inherit from bittensor.Synapse"
+        assert issubclass(param_class, Synapse), (
+            "The first argument of forward_fn must inherit from bittensor.Synapse"
+        )
         request_name = param_class.__name__
 
         async def endpoint(*args, **kwargs):
@@ -580,19 +580,19 @@ async def endpoint(*args, **kwargs):
             blacklist_sig = Signature(
                 expected_params, return_annotation=Tuple[bool, str]
             )
-            assert (
-                signature(blacklist_fn) == blacklist_sig
-            ), f"The blacklist_fn function must have the signature: blacklist( synapse: {request_name} ) -> tuple[bool, str]"
+            assert signature(blacklist_fn) == blacklist_sig, (
+                f"The blacklist_fn function must have the signature: blacklist( synapse: {request_name} ) -> tuple[bool, str]"
+            )
         if priority_fn:
             priority_sig = Signature(expected_params, return_annotation=float)
-            assert (
-                signature(priority_fn) == priority_sig
-            ), f"The priority_fn function must have the signature: priority( synapse: {request_name} ) -> float"
+            assert signature(priority_fn) == priority_sig, (
+                f"The priority_fn function must have the signature: priority( synapse: {request_name} ) -> float"
+            )
         if verify_fn:
             verify_sig = Signature(expected_params, return_annotation=None)
-            assert (
-                signature(verify_fn) == verify_sig
-            ), f"The verify_fn function must have the signature: verify( synapse: {request_name} ) -> None"
+            assert signature(verify_fn) == verify_sig, (
+                f"The verify_fn function must have the signature: verify( synapse: {request_name} ) -> None"
+            )
 
         # Store functions in appropriate attribute dictionaries
         self.forward_class_types[request_name] = param_class
@@ -747,9 +747,9 @@ def check_config(cls, config: "Config"):
         Raises:
             AssertionError: If the axon or external ports are not in range [1024, 65535]
         """
-        assert (
-            1024 < config.axon.port < 65535
-        ), "Axon port must be in range [1024, 65535]"
+        assert 1024 < config.axon.port < 65535, (
+            "Axon port must be in range [1024, 65535]"
+        )
 
         assert config.axon.external_port is None or (
             1024 < config.axon.external_port < 65535

bittensor/core/axon.py

@@ -25,7 +25,7 @@ def _chr_str(codes: tuple[int]) -> str:
 def process_nested(data: Union[tuple, dict], chr_transform):
     """Processes nested data structures by applying a transformation function to their elements."""
     if isinstance(data, (list, tuple)):
-        if len(data) > 0 and isinstance(data[0], dict):
+        if len(data) > 0:
             return [
                 {k: chr_transform(v) for k, v in item.items()}
                 if item is not None