Skip to content

Commit 7616c2b

Browse files
committed
Revert "perf: Optimize content_type filtering with computed column and indexes (#868)"
This reverts commit 3992920.
1 parent c7c2c92 commit 7616c2b

File tree

3 files changed

+4
-46
lines changed

3 files changed

+4
-46
lines changed

deployment/migrations/versions/0040_83a04f64a1db_add_content_type_as_field.py

Lines changed: 0 additions & 34 deletions
This file was deleted.

src/aleph/db/accessors/messages.py

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -130,7 +130,9 @@ def make_matching_messages_query(
130130
MessageDb.content["item_hash"].astext.in_(content_hashes)
131131
)
132132
if content_types:
133-
select_stmt = select_stmt.where(MessageDb.content_type.in_(content_types))
133+
select_stmt = select_stmt.where(
134+
MessageDb.content["type"].astext.in_(content_types)
135+
)
134136
if tags:
135137
select_stmt = select_stmt.where(
136138
MessageDb.content["content"]["tags"].has_any(array(tags))
@@ -314,7 +316,7 @@ def get_unconfirmed_messages(
314316
def make_message_upsert_query(message: MessageDb) -> Insert:
315317
return (
316318
insert(MessageDb)
317-
.values(message.to_dict(exclude={"content_type"}))
319+
.values(message.to_dict())
318320
.on_conflict_do_update(
319321
constraint="messages_pkey",
320322
set_={"time": func.least(MessageDb.time, message.time)},

src/aleph/db/models/messages.py

Lines changed: 0 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -18,9 +18,7 @@
1818
ARRAY,
1919
TIMESTAMP,
2020
Column,
21-
Computed,
2221
ForeignKey,
23-
Index,
2422
Integer,
2523
String,
2624
Table,
@@ -101,14 +99,6 @@ class MessageDb(Base):
10199
time: dt.datetime = Column(TIMESTAMP(timezone=True), nullable=False, index=True)
102100
channel: Optional[Channel] = Column(String, nullable=True, index=True)
103101
size: int = Column(Integer, nullable=False)
104-
content_type: Optional[str] = Column(
105-
String, Computed("content->>'type'", persisted=True)
106-
)
107-
108-
__table_args__ = (
109-
Index("ix_messages_content_type", content_type),
110-
Index("ix_messages_sender_content_type", sender, content_type),
111-
)
112102

113103
confirmations: "List[ChainTxDb]" = relationship(
114104
"ChainTxDb", secondary=message_confirmations

0 commit comments

Comments
 (0)