Fix formatting

Author: MHHukiewitz

src/aleph/sdk/client/authenticated_http.py

@@ -35,7 +35,7 @@
 from aleph_message.status import MessageStatus
 
 from ..conf import settings
-from ..exceptions import BroadcastError, InvalidMessageError, InsufficientFundsError
+from ..exceptions import BroadcastError, InsufficientFundsError, InvalidMessageError
 from ..types import Account, StorageEnum
 from ..utils import extended_json_encoder
 from .abstract import AuthenticatedAlephClient
@@ -691,7 +691,9 @@ async def submit(
             allow_inlining=allow_inlining,
             storage_engine=storage_engine,
         )
-        response, message_status = await self._broadcast(message=message, sync=sync, raise_on_rejected=raise_on_rejected)
+        response, message_status = await self._broadcast(
+            message=message, sync=sync, raise_on_rejected=raise_on_rejected
+        )
         return message, message_status, response
 
     async def _storage_push_file_with_message(

tests/unit/conftest.py

@@ -223,20 +223,27 @@ def get(self, *_args, **_kwargs):
 
 
 @pytest.fixture
-def mock_session_with_rejected_message(ethereum_account, rejected_message) -> AuthenticatedAlephHttpClient:
+def mock_session_with_rejected_message(
+    ethereum_account, rejected_message
+) -> AuthenticatedAlephHttpClient:
     class MockHttpSession(AsyncMock):
         def get(self, *_args, **_kwargs):
             return make_custom_mock_response(rejected_message)
 
         def post(self, *_args, **_kwargs):
-            return make_custom_mock_response({
-                "message_status": "rejected",
-                "publication_status": {"status": "success", "failed": []},
-            }, status=422)
+            return make_custom_mock_response(
+                {
+                    "message_status": "rejected",
+                    "publication_status": {"status": "success", "failed": []},
+                },
+                status=422,
+            )
 
     http_session = MockHttpSession()
 
-    client = AuthenticatedAlephHttpClient(account=ethereum_account, api_server="http://localhost")
+    client = AuthenticatedAlephHttpClient(
+        account=ethereum_account, api_server="http://localhost"
+    )
     client.http_session = http_session
 
     return client

tests/unit/test_asynchronous.py

@@ -189,7 +189,7 @@ async def test_prepare_aleph_message(
 
 @pytest.mark.asyncio
 async def test_create_instance_insufficient_funds_error(
-    mock_session_with_rejected_message
+    mock_session_with_rejected_message,
 ):
     async with mock_session_with_rejected_message as session:
         with pytest.raises(InsufficientFundsError):
@@ -199,4 +199,4 @@ async def test_create_instance_insufficient_funds_error(
                 rootfs_name="rootfs",
                 channel="TEST",
                 metadata={"tags": ["test"]},
-            )
+            )

tests/unit/test_asynchronous_get.py

@@ -4,7 +4,7 @@
 import pytest
 from aleph_message.models import MessagesResponse, MessageType
 
-from aleph.sdk.exceptions import ForgottenMessageError, InvalidMessageError
+from aleph.sdk.exceptions import ForgottenMessageError
 from aleph.sdk.query.filters import MessageFilter, PostFilter
 from aleph.sdk.query.responses import PostsResponse
 from tests.unit.conftest import make_mock_get_session
@@ -87,13 +87,12 @@ async def test_get_forgotten_message():
 
 @pytest.mark.asyncio
 async def test_get_message_error(rejected_message):
-    mock_session = make_mock_get_session(
-        rejected_message
-    )
+    mock_session = make_mock_get_session(rejected_message)
     async with mock_session as session:
         error = await session.get_message_error(rejected_message["item_hash"])
         assert error["error_code"] == rejected_message["error_code"]
         assert error["details"] == rejected_message["details"]
 
+
 if __name__ == "__main __":
     unittest.main()