diff --git a/roles/image-upload-swift/library/image_upload_swift.py b/roles/image-upload-swift/library/image_upload_swift.py index 73bfcad..44081b0 100644 --- a/roles/image-upload-swift/library/image_upload_swift.py +++ b/roles/image-upload-swift/library/image_upload_swift.py @@ -15,6 +15,7 @@ # under the License. import argparse +import concurrent.futures import datetime import logging import os @@ -33,7 +34,11 @@ SEGMENT_SIZE = 500000000 # 500MB def get_cloud(cloud): if isinstance(cloud, dict): config = openstack.config.loader.OpenStackConfig().get_one(**cloud) - return openstack.connection.Connection(config=config) + return openstack.connection.Connection( + config=config, + pool_executor=concurrent.futures.ThreadPoolExecutor( + max_workers=10 + )) else: return openstack.connect(cloud=cloud)