Add Optional to delete owner query

Signed-off-by: dikshathakur3119 <[email protected]>
amundsen-io · Sep 30, 2020 · b58669f · b58669f
1 parent 3ee0924
commit b58669f
Showing 1 changed file with 5 additions and 2 deletions.
diff --git a/metadata_service/proxy/neo4j_proxy.py b/metadata_service/proxy/neo4j_proxy.py
@@ -552,8 +552,11 @@ def delete_owner(self, *,
         :return:
         """
         delete_query = textwrap.dedent("""
-        MATCH (n1:User{key: $user_email})-[r1:OWNER_OF]->(n2:Table {key: $tbl_key})-[r2:OWNER]->(n1) DELETE r1,r2
-        """)
+                MATCH (n1:User{key: $user_email}), (n2:Table {key: $tbl_key})
+                OPTIONAL MATCH (n1)-[r1:OWNER_OF]->(n2)
+                OPTIONAL MATCH (n2)-[r2:OWNER]->(n1) 
+                DELETE r1,r2
+                """)
 
         try:
             tx = self._driver.session().begin_transaction()