         @_createOrUpdate productsToProcess, queriedEntries
       .then (results) =>
         _.each results, (r) =>
-          @_handleProcessResponse(r)
+          if r.isFulfilled()
+            @_handleFulfilledResponse(r)
+          else if r.isRejected()
+            @_handleErrorResponse(r.reason())
+
         Promise.resolve(@_summary)
     , { concurrency: 1 } # run 1 batch at a time
 

      # check if at least one SKU from product is in the blacklist
      isProductBlacklisted = variantSkus.find (sku) ->
        blacklistSkus.indexOf(sku) >= 0

      if isProductBlacklisted
        @_summary.failed++

      # filter only products which are NOT blacklisted
      not isProductBlacklisted

    @publishingStrategy = options.publishingStrategy or false
    @variantReassignmentOptions = options.variantReassignmentOptions or {}
    @reassignmentService = new Reassignment(@client, @logger,
      (error) => @_handleErrorResponse(error),
      @variantReassignmentOptions.retainExistingData)

    @_configErrorHandling(options)
