Multiline string for _get_updated_profile_updates_txn

2026-06-03 19:11:21 +00:00 · 2026-05-27 16:18:41 +03:00
parent c02e6a6181
commit 4e820ca969
1 changed files with 8 additions and 6 deletions
@@ -345,12 +345,14 @@ class ProfileWorkerStore(SQLBaseStore):
        def _get_updated_profile_updates_txn(
            txn: LoggingTransaction,
        ) -> list[tuple[int, str, str]]:
-            sql = (
-                "SELECT stream_id, user_id, field_name"
-                " FROM profile_updates"
-                " WHERE ? < stream_id AND stream_id <= ?"
-                " ORDER BY stream_id ASC LIMIT ?"
-            )
+            sql = """
+            SELECT
+                stream_id, user_id, field_name
+            FROM profile_updates
+            WHERE
+                ? < stream_id AND stream_id <= ?
+            ORDER BY stream_id ASC LIMIT ?
+            """
            txn.execute(sql, (from_id, to_id, limit))
            return cast(list[tuple[int, str, str]], txn.fetchall())