dataimport.py
changeset 9361 0542a85fe667
parent 9181 2eac0aa1d3f6
child 9440 6880674c1a26
child 9448 3e7cad3967c5
--- a/dataimport.py	Thu Dec 12 14:25:24 2013 +0100
+++ b/dataimport.py	Thu Nov 14 17:17:02 2013 +0100
@@ -802,6 +802,9 @@
         assert not rtype.startswith('reverse_')
         self.add_relation(self.session, eid_from, rtype, eid_to,
                           self.rschema(rtype).inlined)
+        if self.rschema[rtype].symmetric:
+            self.add_relation(self.session, eid_to, rtype, eid_from,
+                              self.rschema(rtype).inlined)
         self._nb_inserted_relations += 1
 
     @property
@@ -928,6 +931,9 @@
         # XXX Could subjtype be inferred ?
         self.source.add_relation(self.session, subj_eid, rtype, obj_eid,
                                  self.rschema(rtype).inlined, **kwargs)
+        if self.rschema[rtype].symmetric:
+            self.source.add_relation(self.session, obj_eid, rtype, subj_eid,
+                                     self.rschema(rtype).inlined, **kwargs)
 
     def drop_indexes(self, etype):
         """Drop indexes for a given entity type"""