diff --git a/lib/connector.py b/lib/connector.py index 6efee74b1820a917b1a31241436e98d5a74e7d99..24d4b57b17a87e006ad4393aa12f302b3e08b81a 100644 --- a/lib/connector.py +++ b/lib/connector.py @@ -220,9 +220,9 @@ class Connector(object): external_schemas = connector.config.s3_client.list_objects(Bucket=bucket, Prefix=f"{project_name}/QAF/Schemas/") queries = connector.config.s3_client.list_objects(Bucket=bucket, Prefix=f"{project_name}/QAF/Queries/") if external_schemas.get("Contents"): - for external_schema in external_schemas: - file_path = os.path.join(schema_folder, external_schema["Contents"]["Key"].split('/')[-1]) - connector.config.s3_client.download_file(Bucket=bucket, Key=external_schemas["Contents"]["Key"], Filename = file_path) + for external_schema in external_schemas["Contents"]: + file_path = os.path.join(schema_folder, external_schema["Key"].split('/')[-1]) + connector.config.s3_client.download_file(Bucket=bucket, Key=external_schema["Key"], Filename = file_path) if queries.get("Contents"): for query in queries["Contents"]: file_path = os.path.join(queries_folder, query["Key"].split('/')[-1])