code: def _process_response(self, response):
          
          assert self._state == self._STATE_RUNNING, "Should be running if processing response"
          cols = None
          data = []
          for r in response:
              if not cols:
                  cols = [(f, r._fields[f].db_type) for f in r._fields]
              data.append([getattr(r, f) for f in r._fields])
          self._data = data
          self._columns = cols
          self._state = self._STATE_FINISHED
docs: Update the internal state with the data from the response