     @search @query(), (error, result) =>
       throw error if error?
 
-      connectors = @process @normalize result
+      connectors = @normalize result
       async.each connectors, @update, (error) =>
         throw error if error?
         console.log "it's done...maybe?"

      pathname: "/gateblu_device_add_history/event/#{connector.connector}"

    console.log "updating with connector...", connector
    
    request.put uri, json: connector, (error, response, body) =>
      return callback error if error?
      return callback new Error(JSON.stringify body) if response.statusCode >= 300

  normalize: (result) =>
    buckets = result.aggregations.addGatebluDevice.group_by_connector.buckets
    _.map buckets, (bucket) =>
      connector: bucket.key
      workflow: 'device-add-to-gateblu'
      total: bucket.beginRecord.doc_count
      successes: bucket.endRecord.doc_count
      failures: bucket.beginRecord.doc_count - bucket.endRecord.doc_count

command = new Command()
command.run()
