(self, report)
| 259 | status = cursor.status() |
| 260 | |
| 261 | def update_from_query_report(self, report): |
| 262 | LOG.debug("Updating runtime stats (Query Runner PID: {0})".format(self.proc.pid)) |
| 263 | increment(self._metrics[NUM_QUERIES_FINISHED]) |
| 264 | if report.not_enough_memory: |
| 265 | increment(self._metrics[NUM_QUERIES_EXCEEDED_MEM_LIMIT]) |
| 266 | if report.ac_rejected: |
| 267 | increment(self._metrics[NUM_QUERIES_AC_REJECTED]) |
| 268 | if report.ac_timedout: |
| 269 | increment(self._metrics[NUM_QUERIES_AC_TIMEDOUT]) |
| 270 | if report.was_cancelled: |
| 271 | increment(self._metrics[NUM_QUERIES_CANCELLED]) |
| 272 | |
| 273 | def _cancel(self, cursor, report): |
| 274 | if not report.query_id: |
no test coverage detected