in right_size_your_sagemaker_endpoints/sagemaker_helper.py [0:0]
def deploy_endpoints(endpoints_dict, cpu_model=None, gpu_model=None):
"""
Deploys multiple endpoints concurrently by calling deploy_single_endpoint()
"""
endpoints = []
with concurrent.futures.ThreadPoolExecutor() as executor:
futures = []
for item in endpoints_dict:
futures.append(executor.submit(deploy_single_endpoint, item=item, cpu_model=cpu_model, gpu_model=gpu_model))
for future in concurrent.futures.as_completed(futures):
print(future.result())
endpoints.append(future.result())
return endpoints