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