Missing Error Handling in asyncio.run Method

Description

The provided code snippet lacks error handling techniques within the asyncio.run method, which can lead to unhandled exceptions and potential program crashes. Specifically, if any errors occur during the execution of asynchronous tasks initiated by asyncio.run, they are not caught or handled appropriately.

Code Snippet:

async_tests = TestFactory.async_run(samples_list, model_handler, **kwargs)
temp_res = asyncio.run(async_tests)
results = []
for each in temp_res:
    if hasattr(each, "_result"):
        results.extend(each._result)
    elif isinstance(each, list):
        for i in each:
            if hasattr(i, "_result"):
                results.extend(i._result)
            else:
                results.append(i)

return results

Proposed Solution:

Implement error-catching techniques within the asyncio.run method to handle exceptions gracefully. This can prevent crashes and provide better error reporting to aid in debugging.

Suggested Changes:

Surround the asyncio.run call with a try-except block to catch any exceptions raised during asynchronous execution.
Provide appropriate error handling within the except block, such as logging the error or returning an error message.
Ensure that the error handling mechanism does not disrupt the flow of the program and allows it to gracefully handle errors while continuing execution.

JohnSnowLabs / langtest