             orig_cb?(err, result)
 
         # Finally, do the query.
+        query_queue_exec.label('sent').inc()
         @_do_query(opts)
 
     _update: (state) =>

        tm = new Date()
        @_do_one_query opts, =>
            state.count -= 1
            state.time_ms.push(new Date() - tm)
            if state.time_ms.length > TIME_HISTORY_LENGTH
                state.time_ms.shift()
            @_info(state)

            # point in even trying; the client likely already gave up.
            opts.cb?("timeout")
            cb()
            query_queue_exec.labels('timeout').inc()
            return

        @_dbg("_do_one_query(client_id='#{opts.client_id}') -- doing the query")
