Fix clause change

This commit is contained in:
Eric Eastwood 2024-06-26 02:02:34 -05:00
parent 5c213158d7
commit c60aca755b

View file

@ -934,6 +934,7 @@ class StreamWorkerStore(EventsWorkerStore, SQLBaseStore):
ignore_room_clause, ignore_room_args = make_in_list_sql_clause(
txn.database_engine, "e.room_id", excluded_rooms, negative=True
)
ignore_room_clause = f"AND {ignore_room_clause}"
args += ignore_room_args
sql = """
@ -948,6 +949,8 @@ class StreamWorkerStore(EventsWorkerStore, SQLBaseStore):
ignore_room_clause,
)
logger.info("get_membership_changes_for_user: %s", sql)
txn.execute(sql, args)
rows = [