def get_result(self):
    if self.op.blocks():
        return self._plain_subquery()
    else:
        return self._attempt_pushdown()
def get_result(self):
    if self.op.blocks():
        return self._plain_subquery()
    else:
        return self._attempt_pushdown()