refactor(utils): enforce keyword-only args for functions

Update all function definitions in utils/ to require keyword-only
arguments by adding '*' to their signatures. This improves clarity,
prevents accidental positional argument usage, and aligns with modern Python
best practices for function interfaces.

Author: mkoura

cardano_node_tests/cluster_management/cluster_getter.py

@@ -116,7 +116,7 @@ def instance_dir(self) -> pl.Path:
     def ports(self) -> cardonnay_local.InstancePorts:
         """Return port mappings for current cluster instance."""
         return cluster_nodes.get_cluster_type().cluster_scripts.get_instance_ports(
-            self.cluster_instance_num
+            instance_num=self.cluster_instance_num
         )
 
     def _create_startup_files_dir(self, instance_num: int) -> pl.Path:
@@ -935,7 +935,7 @@ def get_cluster_instance(  # noqa: C901
                     self.log(f"c{instance_num}: can run test '{cget_status.current_test}'")
                     # Set environment variables that are needed when respinning the cluster
                     # and running tests
-                    cluster_nodes.set_cluster_env(instance_num)
+                    cluster_nodes.set_cluster_env(instance_num=instance_num)
 
                     # Remove "prio" status file
                     if prio:

cardano_node_tests/cluster_management/netstat_tools.py

@@ -62,7 +62,9 @@ def _get_proc_cmdline(pid: int) -> str:
 
         return cmdline
 
-    port_nums = cluster_nodes.get_cluster_type().cluster_scripts.get_instance_ports(instance_num)
+    port_nums = cluster_nodes.get_cluster_type().cluster_scripts.get_instance_ports(
+        instance_num=instance_num
+    )
     port_strs = [
         # Add whitestpace to the end of each port number to avoid matching a port number that is a
         # prefix of another port number.

cardano_node_tests/tests/delegation.py

@@ -97,7 +97,7 @@ def cluster_and_pool(
                 if pool_id in stake_pools:
                     return cluster_obj, pool_id
 
-        blocks_before = clusterlib_utils.get_blocks_before(cluster_obj)
+        blocks_before = clusterlib_utils.get_blocks_before(cluster_obj=cluster_obj)
         # Sort pools by how many blocks they produce
         pool_ids_s = sorted(blocks_before, key=blocks_before.get, reverse=True)  # type: ignore
         # Select a pool with reasonable margin

cardano_node_tests/tests/kes.py

@@ -82,7 +82,7 @@ def check_kes_period_info_result(  # noqa: C901
         KesScenarios.INVALID_COUNTERS,
     ):
         instance_ports = cluster_nodes.get_cluster_type().cluster_scripts.get_instance_ports(
-            cluster_nodes.get_instance_num()
+            instance_num=cluster_nodes.get_instance_num()
         )
         prometheus_port = instance_ports.node_ports[pool_num].prometheus
         response = http_client.get_session().get(

cardano_node_tests/tests/test_dbsync_config.py

@@ -73,26 +73,28 @@ def check_dbsync_state(
                 f"Invalid column condition format: {condition}"
             )
             column_condition = condition.value.split(":", 1)[1]
-            dbsync_utils.check_column_condition(table, column, column_condition)
+            dbsync_utils.check_column_condition(
+                table=table, column=column, condition=column_condition
+            )
         else:  # Table-level check
             assert isinstance(condition, TableCondition), (
                 f"Invalid table condition format: {condition}"
             )
             match condition:
                 case TableCondition.EMPTY:
-                    assert dbsync_utils.table_empty(key), (
+                    assert dbsync_utils.table_empty(table=key), (
                         f"Expected {key} to be empty, but it is not."
                     )
                 case TableCondition.NOT_EMPTY:
-                    assert not dbsync_utils.table_empty(key), (
+                    assert not dbsync_utils.table_empty(table=key), (
                         f"Expected {key} to have data, but it is empty."
                     )
                 case TableCondition.EXISTS:
-                    assert dbsync_utils.table_exists(key), (
+                    assert dbsync_utils.table_exists(table=key), (
                         f"Expected {key} to exist, but it does not."
                     )
                 case TableCondition.NOT_EXISTS:
-                    assert not dbsync_utils.table_exists(key), (
+                    assert not dbsync_utils.table_exists(table=key), (
                         f"Expected {key} to NOT exist, but it does."
                     )
                 case _:

cardano_node_tests/tests/test_kes.py

@@ -82,7 +82,7 @@ def cluster_kes(
 
 def _save_metrics(pool_num: int, temp_template: str) -> None:
     instance_ports = cluster_nodes.get_cluster_type().cluster_scripts.get_instance_ports(
-        cluster_nodes.get_instance_num()
+        instance_num=cluster_nodes.get_instance_num()
     )
     port = instance_ports.node_ports[pool_num].prometheus
 

cardano_node_tests/tests/test_metrics.py

@@ -110,7 +110,7 @@ def test_available_metrics(
         """Test that list of available metrics == list of expected metrics."""
         prometheus_port = (
             cluster_nodes.get_cluster_type()
-            .cluster_scripts.get_instance_ports(cluster_nodes.get_instance_num())
+            .cluster_scripts.get_instance_ports(instance_num=cluster_nodes.get_instance_num())
             .prometheus_pool1
         )
 
@@ -133,9 +133,9 @@ def test_available_metrics(
         """Test that available EKG metrics matches the expected schema."""
         ekg_port = (
             cluster_nodes.get_cluster_type()
-            .cluster_scripts.get_instance_ports(cluster_nodes.get_instance_num())
+            .cluster_scripts.get_instance_ports(instance_num=cluster_nodes.get_instance_num())
             .ekg_pool1
         )
 
         response = get_ekg_metrics(ekg_port)
-        model_ekg.Model.validate(response.json())
+        model_ekg.Model.model_validate(response.json())

cardano_node_tests/tests/test_reconnect.py

@@ -242,7 +242,7 @@ def test_metrics_reconnect(
 
         prometheus_port = (
             cluster_nodes.get_cluster_type()
-            .cluster_scripts.get_instance_ports(cluster_nodes.get_instance_num())
+            .cluster_scripts.get_instance_ports(instance_num=cluster_nodes.get_instance_num())
             .prometheus_pool2
         )
 

cardano_node_tests/tests/test_smash.py

@@ -63,9 +63,9 @@ def locked_pool(
         pools_ids = cluster_obj.g_query.get_stake_pools()
         locked_pool_number = pool_name.replace("node-pool", "")
         pattern = re.compile(r"pool" + re.escape(locked_pool_number) + r"(\D|$)")
-        pools = [next(dbsync_queries.query_pool_data(p)) for p in pools_ids]
+        pools = [next(dbsync_queries.query_pool_data(pool_id_bech32=p)) for p in pools_ids]
         locked_pool = next(p for p in pools if p.metadata_url and pattern.search(p.metadata_url))
-        locked_pool_data = dbsync_utils.get_pool_data(locked_pool.view)
+        locked_pool_data = dbsync_utils.get_pool_data(pool_id_bech32=locked_pool.view)
         assert locked_pool_data is not None, "Locked pool data not found!"
         return locked_pool_data
 
@@ -90,7 +90,8 @@ def test_fetch_pool_metadata(
         # Offchain metadata is inserted into database few minutes after start of a cluster
         def _query_func():
             pool_metadata = next(
-                iter(dbsync_queries.query_off_chain_pool_data(locked_pool.view)), None
+                iter(dbsync_queries.query_off_chain_pool_data(pool_id_bech32=locked_pool.view)),
+                None,
             )
             if pool_metadata is None:
                 msg = f"no off-chain pool data record found for pool {pool_id}"
@@ -154,7 +155,7 @@ def pool_cleanup():
         )
         # Ensure re-delisting an already delisted pool returns an error
         try:
-            smash.delist_pool(pool_id)
+            smash.delist_pool(pool_id=pool_id)
         except requests.exceptions.RequestException as err:
             check_request_error(
                 err=err,

cardano_node_tests/tests/tests_conway/test_committee.py

@@ -940,7 +940,10 @@ def _get_res_cert(idx: int, cc_auth: governance_utils.CCMemberAuth) -> pl.Path:
                     _get_res_cert(idx=i, cc_auth=r)
                     for i, r in enumerate((cc_auth_record1, cc_auth_record2, cc_auth_record3))
                     if governance_utils.is_cc_active(
-                        auth_committee_state["committee"].get(f"keyHash-{r.key_hash}") or {}
+                        cc_member_state=auth_committee_state["committee"].get(
+                            f"keyHash-{r.key_hash}"
+                        )
+                        or {}
                     )
                 ]
 
@@ -1830,7 +1833,7 @@ def _check_rat_enact_state(
         constitution_url = web.publish(file_path=constitution_file)
         constitution_hash = cluster.g_governance.get_anchor_data_hash(file_text=constitution_file)
         (
-            const_action,
+            _const_action,
             const_action_txid,
             const_action_ix,
         ) = conway_common.propose_change_constitution(