Lint

synapse/handlers/sync.py

@@ -936,7 +936,7 @@ async def compute_state_delta(
 
     async def unread_notifs_for_room_id(
         self, room_id: str, sync_config: SyncConfig
-    ) -> Optional[Dict[str, str]]:
+    ) -> Optional[Dict[str, int]]:
         with Measure(self.clock, "unread_notifs_for_room_id"):
             last_unread_event_id = await self.store.get_last_receipt_event_id_for_user(
                 user_id=sync_config.user.to_string(),
@@ -1886,7 +1886,7 @@ async def _generate_room_entry(
             )
 
         if room_builder.rtype == "joined":
-            unread_notifications = {}  # type: Dict[str, str]
+            unread_notifications = {}  # type: Dict[str, int]
             room_sync = JoinedSyncResult(
                 room_id=room_id,
                 timeline=batch,

synapse/storage/databases/main/event_push_actions.py

@@ -228,8 +228,7 @@ def _get_count_from_push_actions_txn(
         )
 
         txn.execute(
-            sql % push_actions_column,
-            (user_id, room_id, stream_ordering),
+            sql % push_actions_column, (user_id, room_id, stream_ordering),
         )
         row = txn.fetchone()
         count = row[0] if row else 0
@@ -239,7 +238,8 @@ def _get_count_from_push_actions_txn(
                 """
                 SELECT %s FROM event_push_summary
                 WHERE room_id = ? AND user_id = ? AND stream_ordering > ?
-            """ % push_summary_column,
+            """
+                % push_summary_column,
                 (room_id, user_id, stream_ordering),
             )
             rows = txn.fetchall()
@@ -980,7 +980,7 @@ def _rotate_notifs_before_txn(self, txn, rotate_to_stream_ordering):
         txn.executemany(
             """
                 UPDATE event_push_summary
-                SET notif_count = ?, unread_count = ?, stream_ordering = ? 
+                SET notif_count = ?, unread_count = ?, stream_ordering = ?
                 WHERE user_id = ? AND room_id = ?
             """,
             (

tests/rest/client/v2_alpha/test_sync.py

@@ -477,4 +477,4 @@ def _check_unread_count(self, expected_count: True):
         )
 
         # Store the next batch for the next request.
-        self.next_batch = channel.json_body["next_batch"]
+        self.next_batch = channel.json_body["next_batch"]