@@ -475,11 +475,11 @@ def _sync_properties(self, entity, required_only=False):
475475 continue
476476 if prop .is_output ():
477477 query = f"""
478- MATCH (a:{ entity .class_category } )-[r:{ prop .name } ]->(b)
478+ MATCH (a:{ entity .class_category } )-[r:{ prop .name } ]->(b)
479479 """
480480 elif prop .is_input ():
481481 query = f"""
482- MATCH (a:{ entity .class_category } )<-[r:{ prop .name } ]-(b)
482+ MATCH (a:{ entity .class_category } )<-[r:{ prop .name } ]-(b)
483483 """
484484 query += f"""
485485 WHERE a._obj_id='{ entity .obj_id } '
@@ -614,7 +614,7 @@ def get_runs(
614614 # ambiguous - fully qualified relation
615615 if checkpoint is not None :
616616 query = f"""
617- MATCH (r:Run)-[:checkpoints]->(n) WHERE n._obj_id='{ checkpoint .obj_id } '
617+ MATCH (r:Run)-[:checkpoints]->(n) WHERE n._obj_id='{ checkpoint .obj_id } '
618618 RETURN r._obj_id AS id
619619 """
620620 results = self .connection .read_query (query )
@@ -814,7 +814,7 @@ def _get_entity(
814814 if name is None and entity_license is None and version is None :
815815 self .connection .store .log .warning (f"Requesting all { category } s" )
816816 query = f"""
817- MATCH (n:{ category } ) WHERE n._store='{ self .connection .store .name } '
817+ MATCH (n:{ category } ) WHERE n._store='{ self .connection .store .name } '
818818 RETURN DISTINCT n._obj_id AS id
819819 """
820820 results = self .connection .read_query (query )
@@ -848,7 +848,8 @@ def _get_entity(
848848 if len (entity_obj_ids ) > 0 :
849849 clause = f" AND n._obj_id IN { entity_obj_ids } "
850850 query = f"""
851- MATCH (n)-[:licenses]->(l:License) WHERE l._obj_id='{ entity_license .obj_id } ' { clause }
851+ MATCH (n)-[:licenses]->(l:License)
852+ WHERE l._obj_id='{ entity_license .obj_id } ' { clause }
852853 RETURN DISTINCT n._obj_id AS id
853854 """
854855 results = self .connection .read_query (query )
0 commit comments