formatting

Author: baseballlover723

src/data/rabbitmq_pending_message_data.py

@@ -13,12 +13,10 @@ class RabbitmqPendingMessageModel(BaseModel):
 
 class RabbitmqPendingMessageData(BaseData):
     def get_rabbitmq_pending_message_by_id(self, id: int) -> Optional[RabbitmqPendingMessageModel]:
-        sql = text(
-            """
+        sql = text("""
         SELECT * FROM rabbitmq_pending_messages
         WHERE id = :id;
-        """
-        )
+        """)
 
         result_rows = self.execute(sql, id=id)
         if not result_rows:
@@ -27,12 +25,10 @@ def get_rabbitmq_pending_message_by_id(self, id: int) -> Optional[RabbitmqPendin
         return RabbitmqPendingMessageModel(result_rows[0])
 
     def get_rabbitmq_pending_messages(self) -> list[RabbitmqPendingMessageModel]:
-        sql = text(
-            """
+        sql = text("""
             SELECT * FROM rabbitmq_pending_messages
             ORDER BY created_time ASC;
-            """
-        )
+            """)
 
         result_rows = self.execute(sql)
         return [RabbitmqPendingMessageModel(row) for row in result_rows]

tools/db_migration/versions/20251220T022458Z_add_rabbitmq_pending_table_a5f2ff2c36f8.py

@@ -9,7 +9,6 @@
 from alembic import op
 import sqlalchemy as sa
 
-
 # revision identifiers, used by Alembic.
 revision = "a5f2ff2c36f8"
 down_revision = "03f4360f81fc"
@@ -18,8 +17,7 @@
 
 
 def upgrade():
-    op.execute(
-        """
+    op.execute("""
     CREATE TABLE rabbitmq_pending_messages (
         id BIGSERIAL PRIMARY KEY,
         type TEXT NOT NULL,
@@ -29,13 +27,10 @@ def upgrade():
         created_time TIMESTAMPTZ NOT NULL DEFAULT now()
     );
     CREATE UNIQUE INDEX IF NOT EXISTS idx_rabbitmq_pending_messages_created_time ON rabbitmq_pending_messages(created_time);
-    """
-    )
+    """)
 
 
 def downgrade():
-    op.execute(
-        """
+    op.execute("""
     DROP TABLE IF EXISTS rabbitmq_pending_messages;
-    """
-    )
+    """)