NAS-133327 / 25.04 / Remove @accepts from certain failover endpoints

src/middlewared/middlewared/plugins/failover_/event.py

@@ -13,9 +13,8 @@
 from collections import defaultdict
 
 from middlewared.utils import filter_list
-from middlewared.service import Service, job, accepts
+from middlewared.service import Service, job
 from middlewared.service_exception import CallError
-from middlewared.schema import Dict, Bool, Int
 from middlewared.plugins.docker.state_utils import Status as DockerStatus
 # from middlewared.plugins.failover_.zpool_cachefile import ZPOOL_CACHE_FILE
 from middlewared.plugins.failover_.event_exceptions import AllZpoolsFailedToImport, IgnoreFailoverEvent, FencedError
@@ -87,21 +86,19 @@ async def become_active_service(self, service, timeout):
             timeout=timeout,
         )
 
-    @accepts(Dict(
-        'restart_services',
-        Bool('critical', default=False),
-        Int('timeout', default=15),
-    ))
     async def restart_services(self, data):
         """
         Concurrently restart services during a failover
         master event.
 
-        `critical` Boolean when True will only restart the
-        critical services.
-        `timeout` Integer representing the maximum amount
-        of time to wait for a given service to (re)start.
+        `data` is a dictionary accepting 2 keys
+            `critical` Boolean when True will only restart the
+            critical services.
+            `timeout` Integer representing the maximum amount
+            of time to wait for a given service to (re)start.
         """
+        data.setdefault('critical', False)
+        data.setdefault('timeout', 15)
         to_restart = await self.middleware.call('datastore.query', 'services_services')
         to_restart = [i['srv_service'] for i in to_restart if i['srv_enable']]
         if data['critical']:

src/middlewared/middlewared/plugins/failover_/nftables.py

@@ -5,7 +5,7 @@
 
 from subprocess import run, PIPE, STDOUT
 
-from middlewared.service import Service, accepts, job, CallError
+from middlewared.service import Service, job, CallError
 
 
 FW_RULES_FILE = '/tmp/fw-rules.nft'
@@ -71,7 +71,6 @@ def flush_chain_INPUT(self):
         ip6_flush = not bool(run(['nft', 'flush', 'chain', 'ip6', 'filter', 'INPUT']).returncode)
         return ip4_flush and ip6_flush
 
-    @accepts()
     @job(lock=JOB_LOCK)
     def drop_all(self, job):
         """
@@ -99,7 +98,6 @@ def drop_all(self, job):
 
         return self.generate_rules({'drop': True, 'vips': vips})
 
-    @accepts()
     @job(lock=JOB_LOCK)
     def accept_all(self, job):
         """Accepts all v4/v6 inbound traffic"""

src/middlewared/middlewared/plugins/failover_/zpool_cachefile.py

@@ -4,9 +4,9 @@
 # See the file LICENSE.IX for complete terms and conditions
 
 from pathlib import Path
+from typing import Literal
 
 from middlewared.service import Service
-from middlewared.schema import Str, accepts
 from middlewared.plugins.pool_.utils import ZPOOL_CACHE_FILE
 
 ZPOOL_CACHE_FILE_SAVED = f'{ZPOOL_CACHE_FILE}.saved'
@@ -18,8 +18,10 @@ class Config:
         private = True
         namespace = 'failover.zpool.cachefile'
 
-    @accepts(Str('event', enum=['MASTER', 'BACKUP', 'SYNC'], default='MASTER'))
-    def setup(self, event):
+    def setup(
+        self,
+        event: Literal["MASTER", "BACKUP", "SYNC"] = "MASTER"
+    ):
         saved = Path(ZPOOL_CACHE_FILE_SAVED)
         default = Path(ZPOOL_CACHE_FILE)
         overwrite = Path(ZPOOL_CACHE_FILE_OVERWRITE)