Fix format

Author: jason810496

pgmq_sqlalchemy/queue.py

@@ -124,21 +124,14 @@ def __init__(
         # create pgmq extension if not exists
         self._check_pgmq_ext()
 
-
     def _check_pgmq_ext(self) -> None:
         """Check if the pgmq extension exists."""
-        self._execute_operation(
-            PGMQOperation.check_pgmq_ext,
-            session=None,
-            commit=True
-        )
+        self._execute_operation(PGMQOperation.check_pgmq_ext, session=None, commit=True)
 
     def _check_pg_partman_ext(self) -> None:
         """Check if the pg_partman extension exists."""
         self._execute_operation(
-            PGMQOperation.check_pg_partman_ext,
-            session=None,
-            commit=True
+            PGMQOperation.check_pg_partman_ext, session=None, commit=True
         )
 
     def _execute_operation(
@@ -166,7 +159,6 @@ def _execute_operation(
                 return op_sync(*args, session=s, commit=commit, **kwargs)
         return op_sync(*args, session=session, commit=commit, **kwargs)
 
-
     async def _execute_async_operation(
         self,
         op_async,
@@ -189,8 +181,8 @@ async def _execute_async_operation(
         """
         if session is None:
             async with self.session_maker() as s:
-                return (await op_async(*args, session=s, commit=commit, **kwargs))
-        return (await op_async(*args, session=session, commit=commit, **kwargs))
+                return await op_async(*args, session=s, commit=commit, **kwargs)
+        return await op_async(*args, session=session, commit=commit, **kwargs)
 
     def create_queue(
         self,