Remove flake8 in-line ignores.

taskiq-python · Oct 29, 2024 · 2190328 · 2190328
1 parent ba21951
commit 2190328
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/taskiq_nats/broker.py b/taskiq_nats/broker.py
@@ -35,7 +35,7 @@ class NatsBroker(AsyncBroker):
     https://docs.nats.io/nats-concepts/core-nats/queue
     """
 
-    def __init__(  # (too many args)
+    def __init__(
         self,
         servers: typing.Union[str, typing.List[str]],
         subject: str = "taskiq_tasks",
@@ -88,7 +88,7 @@ async def shutdown(self) -> None:
         await super().shutdown()
 
 
-class BaseJetStreamBroker(  # (too many attrs)
+class BaseJetStreamBroker(
     AsyncBroker,
     ABC,
     typing.Generic[JetStreamConsumerType],
@@ -105,7 +105,7 @@ class BaseJetStreamBroker(  # (too many attrs)
     be sure that messages are delivered to the workers.
     """
 
-    def __init__(  # (too many args)
+    def __init__(
         self,
         servers: typing.Union[str, typing.List[str]],
         subject: str = "taskiq_tasks",

diff --git a/tests/test_jetstream.py b/tests/test_jetstream.py
@@ -53,7 +53,7 @@ async def test_push_based_broker_success(  # (too many await)
 
 
 @pytest.mark.anyio()
-async def test_pull_based_broker_success(  # (too many await)
+async def test_pull_based_broker_success(
     nats_urls: List[str],
     nats_subject: str,
 ) -> None: