|
4 | 4 | import boto3 |
5 | 5 | import time |
6 | 6 | import datetime |
7 | | - |
| 7 | +from botocore.client import Config |
8 | 8 | from rdl.data_sources.ChangeTrackingInfo import ChangeTrackingInfo |
9 | 9 | from rdl.data_sources.SourceTableInfo import SourceTableInfo |
10 | 10 | from rdl.shared import Providers, Constants |
@@ -47,7 +47,8 @@ def __init__(self, connection_string, logger=None): |
47 | 47 | ) |
48 | 48 |
|
49 | 49 | self.aws_lambda_client = self.__get_aws_client( |
50 | | - self.AWS_SERVICE_LAMBDA, role_credentials |
| 50 | + self.AWS_SERVICE_LAMBDA, role_credentials, |
| 51 | + Config(read_timeout=200) |
51 | 52 | ) |
52 | 53 | self.aws_s3_client = self.__get_aws_client( |
53 | 54 | self.AWS_SERVICE_S3, role_credentials |
@@ -182,12 +183,13 @@ def __assume_role(self, role_arn, session_name): |
182 | 183 |
|
183 | 184 | return role_credentials |
184 | 185 |
|
185 | | - def __get_aws_client(self, service, credentials): |
| 186 | + def __get_aws_client(self, service, credentials, config=None): |
186 | 187 | return boto3.client( |
187 | 188 | service_name=service, |
188 | 189 | aws_access_key_id=credentials["AccessKeyId"], |
189 | 190 | aws_secret_access_key=credentials["SecretAccessKey"], |
190 | 191 | aws_session_token=credentials["SessionToken"], |
| 192 | + config=config |
191 | 193 | ) |
192 | 194 |
|
193 | 195 | def __refresh_aws_clients_if_expired(self): |
|
0 commit comments