chore(linter): updating exsiting files

examples/worldstate/custom_models.py

@@ -2,10 +2,7 @@
 from typing import Literal
 
 from warframe.worldstate import WorldstateClient
-from warframe.worldstate.common.core import (  # this import might change
-    SingleQueryModel,
-    TimedEvent,
-)
+from warframe.worldstate.common.core import SingleQueryModel, TimedEvent  # this import might change
 
 
 class CustomCambionDrift(SingleQueryModel, TimedEvent):

examples/worldstate/listeners.py

@@ -31,12 +31,8 @@ async def on_cetus_state_change(cetus: Cetus):
 
 
 async def main():
-    print(
-        (await client.query(OrbVallis))
-    )  # this is just to have a reference to the current state
-    print(
-        (await client.query(Cetus))
-    )  # this is just to have a reference to the current state
+    print((await client.query(OrbVallis)))  # this is just to have a reference to the current state
+    print((await client.query(Cetus)))  # this is just to have a reference to the current state
     on_vallis_state_change.start()  # start the listener
     on_cetus_state_change.start()
     await asyncio.sleep(3600)  # for testing, we wait an hour here

examples/worldstate/query.py

@@ -10,8 +10,12 @@
 async def main():
     async with WorldstateClient() as client:
         # import from models and pass the type you want the object of
-        arbi = await client.query(Arbitration)  # of Type SingleQuery - a single  object  of type `Arbitration`
-        fissures = await client.query(Fissure)  # of Type MultiQuery  - a list of objects of type `Fissure`
+        arbi = await client.query(
+            Arbitration
+        )  # of Type SingleQuery - a single  object  of type `Arbitration`
+        fissures = await client.query(
+            Fissure
+        )  # of Type MultiQuery  - a list of objects of type `Fissure`
 
         print(arbi)
         for fissure in fissures:

warframe/worldstate/client.py

@@ -2,17 +2,7 @@
 import logging
 from datetime import datetime, timezone
 from functools import wraps
-from typing import (
-    Any,
-    Callable,
-    Coroutine,
-    List,
-    Optional,
-    Type,
-    TypeVar,
-    Union,
-    overload,
-)
+from typing import Any, Callable, Coroutine, List, Optional, Type, TypeVar, Union, overload
 
 import aiohttp
 import msgspec
@@ -113,21 +103,15 @@ async def _request(
 
         url = build_endpoint(type, language)
 
-        logging.getLogger(__name__).debug(
-            f"Sending request to the {type.__name__} endpoint"
-        )
+        logging.getLogger(__name__).debug(f"Sending request to the {type.__name__} endpoint")
 
         async with self._session.get(url) as response:
             response_text = await response.text()
 
             if response.status != 200:
-                raise WorldstateAPIError(
-                    msgspec.json.decode(response_text, type=ErrorMessage)
-                )
+                raise WorldstateAPIError(msgspec.json.decode(response_text, type=ErrorMessage))
 
-            logging.getLogger(__name__).debug(
-                f"Got request from the {type.__name__} endpoint"
-            )
+            logging.getLogger(__name__).debug(f"Got request from the {type.__name__} endpoint")
 
             return response_text
 
@@ -227,19 +211,15 @@ async def get_cetus(self, language: Optional[Language] = None) -> Cetus:
         json = await self._request(Cetus, language)
         return Cetus._from_json(json)
 
-    async def get_cambion_drift(
-        self, language: Optional[Language] = None
-    ) -> CambionDrift:
+    async def get_cambion_drift(self, language: Optional[Language] = None) -> CambionDrift:
         json = await self._request(CambionDrift, language)
         return CambionDrift._from_json(json)
 
     async def get_orb_vallis(self, language: Optional[Language] = None) -> OrbVallis:
         json = await self._request(OrbVallis, language)
         return OrbVallis._from_json(json)
 
-    async def get_alerts(
-        self, language: Optional[Language] = None
-    ) -> Optional[List[Alert]]:
+    async def get_alerts(self, language: Optional[Language] = None) -> Optional[List[Alert]]:
         json = await self._request(OrbVallis, language)
         return Alert._from_json(json)
 
@@ -273,12 +253,8 @@ def listen_to(self, type: Type[SingleQueryTimedEvent]):
         Returns:
             _TaskHelper: A helper class that wraps the callback function. Call `.start()` on it in order to start the listener. Same goes for `.stop()`
         """
-        if not issubclass(type, SingleQueryModel) and not not issubclass(
-            type, TimedEvent
-        ):
-            raise TypeError(
-                f"{type.__name__} has to implement SingleQueryModel and TimedEvent"
-            )
+        if not issubclass(type, SingleQueryModel) and not not issubclass(type, TimedEvent):
+            raise TypeError(f"{type.__name__} has to implement SingleQueryModel and TimedEvent")
 
         def decorator(
             func: Callable[[SingleQueryTimedEvent], Coroutine[Any, Any, None]]

warframe/worldstate/enums/__init__.py

@@ -1,4 +1,4 @@
 from .faction import *
-from .mission_type import *
 from .language import *
+from .mission_type import *
 from .syndicate import Syndicate