Update/run pre-commit

Author: ndevenish

.pre-commit-config.yaml

@@ -16,7 +16,7 @@ repos:
   - id: check-yaml
 
 - repo: https://github.com/astral-sh/ruff-pre-commit
-  rev: v0.8.6
+  rev: v0.9.8
   hooks:
     - id: ruff
       args: [--fix, --exit-non-zero-on-fix, --show-fixes]
@@ -31,7 +31,7 @@ repos:
 
 # Type checking
 - repo: https://github.com/pre-commit/mirrors-mypy
-  rev: v1.14.1
+  rev: v1.15.0
   hooks:
   - id: mypy
     files: 'src/.*\.py$'

src/workflows/frontend/__init__.py

@@ -109,9 +109,9 @@ def __getitem__(self, key):
             self._transport_factory = workflows.transport.lookup(transport)
         else:
             self._transport_factory = transport
-        assert hasattr(
-            self._transport_factory, "__call__"
-        ), "No valid transport factory given"
+        assert hasattr(self._transport_factory, "__call__"), (
+            "No valid transport factory given"
+        )
         self._transport = self._transport_factory()
         assert self._transport.connect(), "Could not connect to transport layer"
 

src/workflows/transport/pika_transport.py

@@ -999,9 +999,9 @@ def subscribe_temporary(
         def _declare_subscribe_queue_in_thread():
             try:
                 if result.set_running_or_notify_cancel():
-                    assert (
-                        subscription_id not in self._subscriptions
-                    ), f"Subscription request {subscription_id} rejected due to existing subscription {self._subscriptions[subscription_id]}"
+                    assert subscription_id not in self._subscriptions, (
+                        f"Subscription request {subscription_id} rejected due to existing subscription {self._subscriptions[subscription_id]}"
+                    )
                     temporary_queue_name = (
                         self._get_shared_channel()
                         .queue_declare(
@@ -1543,9 +1543,9 @@ def _add_subscription_in_thread(
         """
         try:
             if result.set_running_or_notify_cancel():
-                assert (
-                    subscription_id not in self._subscriptions
-                ), f"Subscription request {subscription_id} rejected due to existing subscription {self._subscriptions[subscription_id]}"
+                assert subscription_id not in self._subscriptions, (
+                    f"Subscription request {subscription_id} rejected due to existing subscription {self._subscriptions[subscription_id]}"
+                )
                 self._add_subscription(subscription_id, subscription)
                 result.set_result(self._subscriptions[subscription_id].queue)
         except BaseException as e:

tests/recipe/test_recipe.py

@@ -306,13 +306,13 @@ def test_replacing_parameters_in_recipe_with_datastructures():
     A.apply_parameters(replacements)
 
     assert A.recipe[2]["list"] == replacements["some-list"]
-    assert (
-        A.recipe[2]["list"] is not replacements["some-list"]
-    ), "same list returned, not copied"
+    assert A.recipe[2]["list"] is not replacements["some-list"], (
+        "same list returned, not copied"
+    )
     assert A.recipe[2]["dictionary"] == replacements["nested"]
-    assert (
-        A.recipe[2]["dictionary"] is not replacements["nested"]
-    ), "same dictionary returned, not copied"
+    assert A.recipe[2]["dictionary"] is not replacements["nested"], (
+        "same dictionary returned, not copied"
+    )
     assert (
         A.recipe[2]["dictionary"]["some-dictionary"]
         is not replacements["nested"]["some-dictionary"]

tests/transport/test_pika.py

@@ -1309,9 +1309,9 @@ def test_full_stack_temporary_queue_roundtrip(pikatransport):
 
     def assert_not_seen_before(ts: TemporarySubscription):
         assert ts.subscription_id, "Temporary subscription is missing an ID"
-        assert (
-            ts.subscription_id not in known_subscriptions
-        ), "Duplicate subscription ID"
+        assert ts.subscription_id not in known_subscriptions, (
+            "Duplicate subscription ID"
+        )
         assert ts.queue_name, "Temporary queue does not have a name"
         assert ts.queue_name not in known_queues, "Duplicate temporary queue name"
         known_subscriptions.add(ts.subscription_id)

tests/transport/test_stomp.py

@@ -600,9 +600,9 @@ def test_subscribe_to_temporary_queue(mockstomp):
 
     def assert_not_seen_before(ts: TemporarySubscription):
         assert ts.subscription_id, "Temporary subscription is missing an ID"
-        assert (
-            ts.subscription_id not in known_subscriptions
-        ), "Duplicate subscription ID"
+        assert ts.subscription_id not in known_subscriptions, (
+            "Duplicate subscription ID"
+        )
         assert ts.queue_name, "Temporary queue does not have a name"
         assert ts.queue_name not in known_queues, "Duplicate temporary queue name"
         known_subscriptions.add(ts.subscription_id)