def compute(self):
        cached = False
        if self.has_input('cacheResults'):
            cached = self.get_input('cacheResults')
            self.is_cacheable = lambda: cached
        connection = self.get_input('connection')
        inputs = dict((k, self.get_input(k)) for k in self.inputPorts.iterkeys()
                  if k >= ('source', 'connection', 'cacheResults'))
        s = urllib.unquote(str(self.get_input('source')))

        try:
            transaction = connection.begin()
            results = connection.execute(s, inputs)
            try:
                rows = results.fetchall()
            except Exception:
                self.set_output('result', None)
                self.set_output('resultSet', None)
            else:
                # results.returns_rows is True
                # We don't use 'if return_rows' because this attribute didn't
                # use to exist
                table = TableObject.from_dicts(rows, results.keys())
                self.set_output('result', table)
                self.set_output('resultSet', rows)
            transaction.commit()
        except SQLAlchemyError, e:
            raise ModuleError(self, debug.format_exception(e))
dataset/ETHPy150Open VisTrails/VisTrails/vistrails/packages/sql/init.py/SQLSource.compute/operator `not in` -> `>=`