Merge pull request #104 from MattExact/postgres-disk-full

Avoid a disk full condition for Postgres servers
long2ice · May 20, 2024 · f837e60 · f837e60
2 parents aebac61 + ab0a0c5
commit f837e60
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/meilisync/source/postgres.py b/meilisync/source/postgres.py
@@ -130,6 +130,10 @@ def _consumer(self, msg: ReplicationMessage):
                 )
             )
 
+            # Report success to the server to avoid a “disk full” condition.
+            # https://www.psycopg.org/docs/extras.html#psycopg2.extras.ReplicationCursor.consume_stream
+            msg.cursor.send_feedback(flush_lsn=msg.data_start)
+
     async def get_count(self, sync: Sync):
         with self.conn_dict.cursor() as cur:
             cur.execute(f"SELECT COUNT(*) FROM {sync.table}")