         else
           Promise.resolve(msg.body.CHANNEL_ID)
 
-      @client.inventoryEntries.where("sku=\"#{@_escapeSku(msg.body.SKU)}\"").perPage(1).fetch()
+      @client.inventoryEntries.where("sku=#{@_escapeSku(msg.body.SKU)}").perPage(1).fetch()
       .then (results) =>
         debug 'Existing entries: %j', results
         existingEntries = results.body.results

      skus = _.map uniqueStocksToProcessBySku, (s) =>
        @_summary.emptySKU++ if _.isEmpty s.sku
        # TODO: query also for channel?
        "\"#{@_escapeSku(s.sku)}\""
      predicate = "sku in (#{skus.join(', ')})"

      @client.inventoryEntries.all()

      else throw new Error "Unsupported mode (file extension) for file #{fileName} (use csv or xml)"

  _escapeSku: (sku) ->
    JSON.stringify(sku)

  ###
  Elastic.io calls this for each csv row, so each inventory entry will be processed at a time
