

def query(self, *entities, **filter_by):
    if (entities and isinstance(entities[0], LogicalConnective)):
        q = self.g.query(self.element_cls)
        return q.filter(entities[0]).filter_by(**filter_by)
    else:
        return self.g.query(self.element_cls, *entities).filter_by(**filter_by)

dataset/ETHPy150Open mogui/pyorient/pyorient/ogm/broker.py Broker.query/original