Add an index to the pending_messages table on the time field

Author: aliel

deployment/migrations/versions/35a67ccc4451_add_pending_message_index_on_time_field.py

@@ -0,0 +1,26 @@
+"""Add pending_message index on time field
+
+Revision ID: 35a67ccc4451
+Revises: 8ece21fbeb47
+Create Date: 2025-09-04 08:29:17.540060
+
+"""
+from alembic import op
+
+# revision identifiers, used by Alembic.
+revision = '35a67ccc4451'
+down_revision = '8ece21fbeb47'
+branch_labels = None
+depends_on = None
+
+
+def upgrade() -> None:
+    # ### commands auto generated by Alembic - please adjust! ###
+    op.create_index(op.f('ix_pending_messages_time'), 'pending_messages', ['time'], unique=False)
+    # ### end Alembic commands ###
+
+
+def downgrade() -> None:
+    # ### commands auto generated by Alembic - please adjust! ###
+    op.drop_index(op.f('ix_pending_messages_time'), table_name='pending_messages')
+    # ### end Alembic commands ###

src/aleph/db/models/pending_messages.py

@@ -58,7 +58,7 @@ class PendingMessageDb(Base):
     item_type: ItemType = Column(ChoiceType(ItemType), nullable=False)
     item_content = Column(String, nullable=True)
     content: Optional[Dict[str, Any]] = Column(JSONB, nullable=True)
-    time: dt.datetime = Column(TIMESTAMP(timezone=True), nullable=False)
+    time: dt.datetime = Column(TIMESTAMP(timezone=True), nullable=False, index=True)
     channel: Optional[Channel] = Column(String, nullable=True)
 
     reception_time: dt.datetime = Column(TIMESTAMP(timezone=True), nullable=False)