lint: action all ruff fixes

Author: willcl-ark

resources/plugins/hello/plugin.py

@@ -72,15 +72,15 @@ def entrypoint(ctx, plugin_content: str, warnet_content: str):
 
     hook_value = warnet_content.get(WarnetContent.HOOK_VALUE.value)
 
-    assert hook_value in {
-        item.value for item in HookValue
-    }, f"{hook_value} is not a valid HookValue"
+    assert hook_value in {item.value for item in HookValue}, (
+        f"{hook_value} is not a valid HookValue"
+    )
 
     if warnet_content.get(PLUGIN_ANNEX):
         for annex_member in [annex_item for annex_item in warnet_content.get(PLUGIN_ANNEX)]:
-            assert annex_member in {
-                item.value for item in AnnexMember
-            }, f"{annex_member} is not a valid AnnexMember"
+            assert annex_member in {item.value for item in AnnexMember}, (
+                f"{annex_member} is not a valid AnnexMember"
+            )
 
     warnet_content[WarnetContent.HOOK_VALUE.value] = HookValue(hook_value)
 

resources/plugins/simln/plugin.py

@@ -63,15 +63,15 @@ def entrypoint(ctx, plugin_content: str, warnet_content: str):
 
     hook_value = warnet_content.get(WarnetContent.HOOK_VALUE.value)
 
-    assert hook_value in {
-        item.value for item in HookValue
-    }, f"{hook_value} is not a valid HookValue"
+    assert hook_value in {item.value for item in HookValue}, (
+        f"{hook_value} is not a valid HookValue"
+    )
 
     if warnet_content.get(PLUGIN_ANNEX):
         for annex_member in [annex_item for annex_item in warnet_content.get(PLUGIN_ANNEX)]:
-            assert annex_member in {
-                item.value for item in AnnexMember
-            }, f"{annex_member} is not a valid AnnexMember"
+            assert annex_member in {item.value for item in AnnexMember}, (
+                f"{annex_member} is not a valid AnnexMember"
+            )
 
     warnet_content[WarnetContent.HOOK_VALUE.value] = HookValue(hook_value)
 

resources/scenarios/commander.py

@@ -11,10 +11,10 @@
 import tempfile
 import threading
 from time import sleep
-from typing import Dict
 
 from kubernetes import client, config
 from ln_framework.ln import LND
+
 from test_framework.authproxy import AuthServiceProxy
 from test_framework.p2p import NetworkThread
 from test_framework.test_framework import (
@@ -160,8 +160,8 @@ def setup(self):
         self.log.addHandler(ch)
 
         # Keep a separate index of tanks by pod name
-        self.tanks: Dict[str, TestNode] = {}
-        self.lns: Dict[str, LND] = {}
+        self.tanks: dict[str, TestNode] = {}
+        self.lns: dict[str, LND] = {}
         self.channels = WARNET["channels"]
 
         for i, tank in enumerate(WARNET["tanks"]):

resources/scenarios/ln_init.py

@@ -261,9 +261,9 @@ def open_channel(self, ch, fee_rate):
             block_height = block["height"]
             for ch in channels:
                 assert ch["id"]["block"] == block_height, f"Actual block:{block_height}\n{ch}"
-                assert (
-                    block_txs[ch["id"]["index"]] == ch["txid"]
-                ), f"Actual txid:{block_txs[ch["id"]["index"]]}\n{ch}"
+                assert block_txs[ch["id"]["index"]] == ch["txid"], (
+                    f"Actual txid:{block_txs[ch['id']['index']]}\n{ch}"
+                )
             self.log.info("👍")
 
         gen(5)
@@ -294,9 +294,9 @@ def ln_all_chs(self, ln):
         def update_policy(self, ln, txid_hex, policy, capacity):
             self.log.info(f"Sending update from {ln.name} for channel with outpoint: {txid_hex}:0")
             res = ln.update(txid_hex, policy, capacity)
-            assert (
-                len(res["failed_updates"]) == 0
-            ), f" Failed updates: {res["failed_updates"]}\n txid: {txid_hex}\n policy:{policy}"
+            assert len(res["failed_updates"]) == 0, (
+                f" Failed updates: {res['failed_updates']}\n txid: {txid_hex}\n policy:{policy}"
+            )
 
         update_threads = []
         for ch in self.channels:

src/warnet/bitcoin.py

@@ -6,9 +6,10 @@
 from typing import Optional
 
 import click
+from urllib3.exceptions import MaxRetryError
+
 from test_framework.messages import ser_uint256
 from test_framework.p2p import MESSAGEMAP
-from urllib3.exceptions import MaxRetryError
 
 from .constants import BITCOINCORE_CONTAINER
 from .k8s import get_default_namespace_or, get_mission, pod_log

test/test_base.py

@@ -60,9 +60,9 @@ def _print_and_assert_msgs(self, message):
             self.log_msg_assertions_passed = True
 
     def assert_log_msgs(self):
-        assert (
-            self.log_msg_assertions_passed
-        ), f"Log assertion failed. Expected message not found: {self.log_expected_msgs}"
+        assert self.log_msg_assertions_passed, (
+            f"Log assertion failed. Expected message not found: {self.log_expected_msgs}"
+        )
         self.log_msg_assertions_passed = False
 
     def warnet(self, cmd):