def upload_files_multithreaded(ctx, asset_id, asset_type, filepaths, chunk_size=-1):
  pool = ThreadPool(len(filepaths))
  for filepath in filepaths:
    print "begin %s" % (filepath)
    pool.apply_async(upload_file_worker, args=(ctx, asset_id, asset_type, filepath, chunk_size,)).wait(timeout=1)
  pool.close()
  pool.join()
Upload a given set of files to an asset simultaneously.
dataset/ETHPy150Open keithmoss/Hodor/hodor/gme.py/upload_files_multithreaded