Problem: new version of black invalidates prior formatting

Solution: update black and reformat files

Author: MHHukiewitz

examples/httpgateway.py

@@ -1,5 +1,6 @@
 """ Server metrics upload.
 """
+
 # -*- coding: utf-8 -*-
 
 import click

examples/metrics.py

@@ -1,5 +1,6 @@
 """ Server metrics upload.
 """
+
 import asyncio
 import os
 import platform

examples/mqtt.py

@@ -1,5 +1,6 @@
 """ Server metrics upload.
 """
+
 # -*- coding: utf-8 -*-
 
 import asyncio

src/aleph/sdk/chains/nuls1.py

@@ -1,5 +1,6 @@
 """ Barebone NULS address and message signing support.
 """
+
 import hashlib
 import logging
 import struct

src/aleph/sdk/chains/remote.py

@@ -1,6 +1,7 @@
 """
 Remote account, accessible via an API.
 """
+
 import asyncio
 from typing import Dict, Optional
 

src/aleph/sdk/client/authenticated_http.py

@@ -476,9 +476,11 @@ async def create_program(
             runtime=FunctionRuntime(
                 ref=runtime,
                 use_latest=True,
-                comment="Official aleph.im runtime"
-                if runtime == settings.DEFAULT_RUNTIME_ID
-                else "",
+                comment=(
+                    "Official aleph.im runtime"
+                    if runtime == settings.DEFAULT_RUNTIME_ID
+                    else ""
+                ),
             ),
             volumes=[parse_volume(volume) for volume in volumes],
             time=time.time(),
@@ -549,9 +551,11 @@ async def create_instance(
                 size_mib=rootfs_size,
                 persistence="host",
                 use_latest=True,
-                comment="Official Aleph Debian root filesystem"
-                if rootfs == settings.DEFAULT_RUNTIME_ID
-                else "",
+                comment=(
+                    "Official Aleph Debian root filesystem"
+                    if rootfs == settings.DEFAULT_RUNTIME_ID
+                    else ""
+                ),
             ),
             volumes=[parse_volume(volume) for volume in volumes],
             time=time.time(),

src/aleph/sdk/conf.py

@@ -29,7 +29,9 @@ class Settings(BaseSettings):
     REMOTE_CRYPTO_UNIX_SOCKET: Optional[str] = None
     ADDRESS_TO_USE: Optional[str] = None
 
-    DEFAULT_RUNTIME_ID: str = "f873715dc2feec3833074bd4b8745363a0e0093746b987b4c8191268883b2463"  # Debian 12 official runtime
+    DEFAULT_RUNTIME_ID: str = (
+        "f873715dc2feec3833074bd4b8745363a0e0093746b987b4c8191268883b2463"  # Debian 12 official runtime
+    )
     DEFAULT_VM_MEMORY: int = 256
     DEFAULT_VM_VCPUS: int = 1
     DEFAULT_VM_TIMEOUT: float = 30.0

src/aleph/sdk/types.py

@@ -18,23 +18,19 @@ class Account(Protocol):
     CURVE: str
 
     @abstractmethod
-    async def sign_message(self, message: Dict) -> Dict:
-        ...
+    async def sign_message(self, message: Dict) -> Dict: ...
 
     @abstractmethod
-    def get_address(self) -> str:
-        ...
+    def get_address(self) -> str: ...
 
     @abstractmethod
-    def get_public_key(self) -> str:
-        ...
+    def get_public_key(self) -> str: ...
 
 
 class AccountFromPrivateKey(Account, Protocol):
     """Only accounts that are initialized from a private key string are supported."""
 
-    def __init__(self, private_key: bytes):
-        ...
+    def __init__(self, private_key: bytes): ...
 
 
 GenericMessage = TypeVar("GenericMessage", bound=AlephMessage)

src/aleph/sdk/utils.py

@@ -98,13 +98,11 @@ def check_unix_socket_valid(unix_socket_path: str) -> bool:
 
 
 class AsyncReadable(Protocol[T]):
-    async def read(self, n: int = -1) -> T:
-        ...
+    async def read(self, n: int = -1) -> T: ...
 
 
 class Writable(Protocol[U]):
-    def write(self, buffer: U) -> int:
-        ...
+    def write(self, buffer: U) -> int: ...
 
 
 async def copy_async_readable_to_buffer(

tests/unit/conftest.py

@@ -130,9 +130,9 @@ def json_post() -> dict:
 @pytest.fixture
 def raw_messages_response(aleph_messages) -> Callable[[int], Dict[str, Any]]:
     return lambda page: {
-        "messages": [message.dict() for message in aleph_messages]
-        if int(page) == 1
-        else [],
+        "messages": (
+            [message.dict() for message in aleph_messages] if int(page) == 1 else []
+        ),
         "pagination_item": "messages",
         "pagination_page": int(page),
         "pagination_per_page": max(len(aleph_messages), 20),
@@ -158,11 +158,9 @@ def __init__(self, sync: bool):
     async def __aenter__(self):
         return self
 
-    async def __aexit__(self, exc_type, exc_val, exc_tb):
-        ...
+    async def __aexit__(self, exc_type, exc_val, exc_tb): ...
 
-    async def raise_for_status(self):
-        ...
+    async def raise_for_status(self): ...
 
     @property
     def status(self):

tests/unit/test_chain_nuls1_compat.py

@@ -2,6 +2,7 @@
 
 This file tests that both implementations returns identical results.
 """
+
 from pathlib import Path
 from tempfile import NamedTemporaryFile