prints

inbox/mailsync/backends/imap/common.py

@@ -258,6 +258,8 @@ def remove_deleted_uids(account_id: int, folder_id: int, uids: Iterable[int]) ->
     with session_scope(account_id) as db_session:
         category_type = Account.get(account_id, db_session).category_type
 
+        print("before message_ids_and_uid")
+
         message_ids_and_uid = (
             db_session.query(ImapUid.message_id, ImapUid.msg_uid)
             .filter(
@@ -271,10 +273,16 @@ def remove_deleted_uids(account_id: int, folder_id: int, uids: Iterable[int]) ->
             .all()
         )
 
+        print("after message_ids_and_uid")
+
+    print("before uids_by_message_id")
+
     uids_by_message_id = defaultdict(list)
     for message_id, message_uid in message_ids_and_uid:
         uids_by_message_id[message_id].append(message_uid)
 
+    print("after uids_by_message_id")
+
     for message_id, message_uids in uids_by_message_id.items():
         with session_scope(account_id) as db_session:
             db_session.query(ImapUid).filter(
@@ -287,6 +295,8 @@ def remove_deleted_uids(account_id: int, folder_id: int, uids: Iterable[int]) ->
                 synchronize_session=False
             )
 
+            print(message_id, len(message_uids))
+
             deleted_uid_count += len(message_uids)
 
             message = db_session.query(Message).get(message_id)
@@ -321,7 +331,10 @@ def remove_deleted_uids(account_id: int, folder_id: int, uids: Iterable[int]) ->
                         # 'deleted' and wait for the asynchronous
                         # dangling-message-collector to delete them.
                         message.mark_for_deletion()
+
+            print("before commit")
             db_session.commit()
+            print("after commit")
     log.info("Deleted expunged UIDs", count=deleted_uid_count)