corpora_ids_and_display_names = [('bucket_dir_1', 'projects/$PROJECT_NUMBER/locations/us-central1/ragCorpora/$CORPUS_ID_1'), ('bucket_dir_2', 'projects/$PROJECT_NUMBER/locations/us-central1/ragCorpora/$CORPUS_ID_2')]

async def import_files_async(corpus_id_and_display_name: tuple):
    try:
        response = await rag.import_files_async(
            corpus_name=corpus_id_and_display_name[1],
            paths=[f"gs://some-bucket/{corpus_id_and_display_name[0]}"],
        )
        return response
    except Exception as e:
        print(f"error: {e}")

async def create_import_files_task_group_async():
    coros = [import_files_async(corpus_id_and_display_name) for corpus_id_and_display_name in corpora_ids_and_display_names]
    import_files_task_group = [asyncio.create_task(coro) for coro in coros]
    results = await asyncio.gather(*import_files_task_group, return_exceptions=True)
    print(f"results: {results}")

asyncio.run(create_import_files_task_group_async())

# final asyncio.gather/asyncio.run response -- no errors
results: [<google.api_core.operation_async.AsyncOperation object at 0x10eaff4d0>, <google.api_core.operation_async.AsyncOperation object at 0x10eaf2fd0>, <google.api_core.operation_async.AsyncOperation object at 0x10ec48590>, <google.api_core.operation_async.AsyncOperation object at 0x10eaf1ba0>, <google.api_core.operation_async.AsyncOperation object at 0x10eafee90>]

# works to list corpora hence corpora paths are correct
for corpus_id_and_display_name in corpora_ids_and_display_names:
    print(rag.list_files(corpus_name=corpus_id_and_display_name[1]))

# works to list all files in each bucket path hence import_files_async
# has valid paths argument
for corpus_id_and_display_name in corpora_ids_and_display_names:
    subprocess.run(['gcloud storage ls', f"gs://bucket/{corpus_id_and_display_name[0]}"])