def upload_block()

in ambari-infra-solr-client/src/main/python/solrDataManager.py [0:0]

• 31 lines of code
• 7 McCabe index (conditional complexity)

def upload_block(mode, solr_kinit_command, hdfs_kinit_command, curl_prefix, solr_url, collection, filter_field,
                 id_field, working_dir, tmp_file_path, name, prev_lot_end_value, prev_lot_end_id, hdfs_user, hdfs_path,
                 key_file_path, bucket, key_prefix, local_path, compression, solr_output_collection, solr_output_url,
                 skip_date_usage):
  if name:
    file_name = "{0}_-_{1}_-_{2}_-_{3}".format(collection, name, prev_lot_end_value, prev_lot_end_id).replace(':', '_')
  else:
    file_name = "{0}_-_{1}_-_{2}".format(collection, prev_lot_end_value, prev_lot_end_id).replace(':', '_')

  upload_file_path = compress_file(working_dir, tmp_file_path, file_name, compression)

  upload_command = create_command_file(mode, True, working_dir, upload_file_path, solr_url, collection, filter_field,
                                       id_field, prev_lot_end_value, prev_lot_end_id, hdfs_user, hdfs_path,
                                       key_file_path, bucket, key_prefix, local_path, solr_output_collection, solr_output_url,
                                       skip_date_usage)
  if solr_output_collection:
    upload_file_to_solr(solr_kinit_command, curl_prefix, upload_command, upload_file_path, solr_output_collection)
  elif hdfs_user:
    upload_file_hdfs(hdfs_kinit_command, upload_command, upload_file_path, hdfs_path, hdfs_user)
  elif key_file_path:
    upload_file_s3(upload_command, upload_file_path, bucket, key_prefix)
  elif local_path:
    upload_file_local(upload_command, upload_file_path, local_path)
  else:
    logger.warn("Unknown upload destination")
    sys.exit()

  delete_command = create_command_file(mode, False, working_dir, upload_file_path, solr_url, collection, filter_field,
                                       id_field, prev_lot_end_value, prev_lot_end_id, None, None, None, None, None, None, None,
                                       None, skip_date_usage)
  if mode == "archive":
    delete_data(solr_kinit_command, curl_prefix, delete_command, collection, filter_field, id_field, prev_lot_end_value,
                prev_lot_end_id, skip_date_usage)
    os.remove("{0}/command.json".format(working_dir))