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

@@ -7,8 +7,6 @@
 """
 
 from alembic import op
-import sqlalchemy as sa
-
 
 # revision identifiers, used by Alembic.
 revision = "a5f2ff2c36f8"
@@ -18,8 +16,7 @@
 
 
 def upgrade():
-    op.execute(
-        """
+    op.execute("""
     CREATE TABLE rabbitmq_pending_messages (
         id BIGSERIAL PRIMARY KEY,
         type TEXT NOT NULL,
@@ -28,14 +25,12 @@ def upgrade():
         json_body JSONB NOT NULL,
         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);
-    """
-    )
+    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;
-    """
-    )
+    """)