anchor.diff:    req = Net::HTTP::Post.new(uri.request_uri)
   
     response = http.request(req)
  -  raise "Error queueing oid: #{oid}, job id: #{job_id}. Response: #{response.code}, body: #{response.body}" unless response.code.to_i == 200
  +  fail "Error queueing oid: #{oid}, job id: #{job_id}. Response: #{response.code}, body: #{response.body}" unless response.code.to_i == 200
   end
   
   def send_to_legacy_importer(org_slug, path, compression, is_full_import)
  
positive.code:   )
  
    response = http.request(req)
    raise "Error sending #{path}. Response: #{response.code}, body: #{response.body}" unless response.code.to_i == 200
  end
  
  def compress_if_not_already(path, compression)
  
negative.code:   }
  
    response = http.request(req)
    fail "Error sending oid: #{oid}, file: #{s3_filename}. Response: #{response.code}, body: #{response.body}" unless response.code.to_i == 200
  
    body = JSON.parse(response.body)
    body['id']
  