def execute(self, quals, columns):
        conn = httplib.HTTPConnection(self.host, self.port)
        conn.request("GET", "/%s/%s/_search?q=*:*&size=100000000" % (self.node, self.index))
        resp = conn.getresponse()
        if not 200 == resp.status:
            return (0, 0)

        raw = resp.read()
        data = json.loads(raw)
        out = []
        for hit in data['hits']['hits']:
            row = {}
            for col in columns:
                if col == 'id':
                    row[col] = hit['_id']
                elif hit['_source'] in col:
                    row[col] = hit['_source'][col]
            out.append(row)

        return out
dataset/ETHPy150Open Mikulas/pg-es-fdw/dite/__init__.py/ElasticsearchFDW.execute/swapped operands of `in`