code review improvements

Author: leodisarli

src/omniq/consumer.py

@@ -67,14 +67,12 @@ def hb_loop():
     t.start()
     return HeartbeatHandle(stop_evt=stop_evt, flags=flags, thread=t)
 
-
 def _safe_log(logger: Callable[[str], None], msg: str) -> None:
     try:
         logger(msg)
     except Exception:
         pass
 
-
 def _payload_preview(payload: Any, max_len: int = 300) -> str:
     try:
         s = payload if isinstance(payload, str) else json.dumps(payload, ensure_ascii=False)
@@ -84,7 +82,6 @@ def _payload_preview(payload: Any, max_len: int = 300) -> str:
         return s[:max_len] + "…"
     return s
 
-
 def consume(
     client: OmniqClient,
     *,