code review improvements

Author: leodisarli

src/omniq/_ops.py

@@ -504,7 +504,6 @@ def child_ack(self, *, key: str, child_id: str) -> int:
         except Exception:
             return -1
 
-
     @staticmethod
     def paused_backoff_s(poll_interval_s: float) -> float:
         return max(0.25, float(poll_interval_s) * 10.0)

src/omniq/exec.py

@@ -3,7 +3,6 @@
 
 from .client import OmniqClient
 
-
 @dataclass(frozen=True)
 class Exec:
     client: OmniqClient

src/omniq/scripts.py

@@ -3,17 +3,14 @@
 from threading import Lock
 from typing import Protocol
 
-
 class ScriptLoader(Protocol):
     def script_load(self, script: str) -> str: ...
 
-
 @dataclass(frozen=True)
 class ScriptDef:
     sha: str
     src: str
 
-
 @dataclass(frozen=True)
 class OmniqScripts:
     enqueue: ScriptDef
@@ -32,15 +29,13 @@ class OmniqScripts:
     childs_init: ScriptDef
     child_ack: ScriptDef
 
-
 def default_scripts_dir() -> str:
     here = os.path.dirname(__file__)
     return os.path.join(here, "core", "scripts")
 
 _scripts_cache: dict[str, OmniqScripts] = {}
 _scripts_cache_lock = Lock()
 
-
 def load_scripts(r: ScriptLoader, scripts_dir: str) -> OmniqScripts:
     with _scripts_cache_lock:
         cached = _scripts_cache.get(scripts_dir)

src/omniq/transport.py

@@ -10,7 +10,6 @@
 
 RedisArg = Union[str, bytes, int, float]
 
-
 class RedisLike(Protocol):
     def evalsha(self, sha: str, numkeys: int, *args: RedisArg) -> Any: ...
     def eval(self, script: str, numkeys: int, *args: RedisArg) -> Any: ...