check all changes in replication message

long2ice · May 7, 2024 · 0be3c1e · 0be3c1e
1 parent e144418
commit 0be3c1e
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/meilisync/source/postgres.py b/meilisync/source/postgres.py
@@ -95,7 +95,7 @@ def _consumer(self, msg: ReplicationMessage):
             kind = change.get("kind")
             table = change.get("table")
             if table not in self.tables:
-                return
+                continue
             columnnames = change.get("columnnames", [])
             columnvalues = change.get("columnvalues", [])
             columntypes = change.get("columntypes", [])