Merge pull request #35 from GnosisAI/dev

Fix: Delete Failures in Postgres Handled
long2ice · Nov 29, 2023 · bd93072 · bd93072
2 parents 427dd2f + 5c98d02
commit bd93072
Showing 1 changed file with 12 additions and 1 deletion.
diff --git a/meilisync/source/postgres.py b/meilisync/source/postgres.py
@@ -81,12 +81,23 @@ def _consumer(self, msg: ReplicationMessage):
                 return
             columnnames = change.get("columnnames")
             columnvalues = change.get("columnvalues")
-            values = dict(zip(columnnames, columnvalues))
+
             if kind == "update":
+                values = dict(zip(columnnames, columnvalues))
                 event_type = EventType.update
             elif kind == "delete":
+                values = (
+                    dict(zip(columnnames, columnvalues))
+                    if columnvalues
+                    else {
+                        change["oldkeys"]["keynames"][0]: change["oldkeys"][
+                            "keyvalues"
+                        ][0]
+                    }
+                )
                 event_type = EventType.delete
             elif kind == "insert":
+                values = dict(zip(columnnames, columnvalues))
                 event_type = EventType.create
             else:
                 return