Merge pull request #101 from MattExact/postgres-check-all-changes

Postgres: Check all changes in replication message
long2ice · May 7, 2024 · aebac61 · aebac61
2 parents e144418 + 0be3c1e
commit aebac61
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", [])