feat(ingest/dbt-core): support fetching using the s3a protocol (#12465)

Co-authored-by: hzhang <hzhang@ssnc-corp.global>
This commit is contained in:
hao zhang 2025-01-30 16:13:47 +08:00 committed by GitHub
parent 6acd94b436
commit c8e88aef09
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194

View File

@ -488,7 +488,7 @@ class DBTCoreSource(DBTSourceBase, TestableSource):
) -> Dict:
if re.match("^https?://", uri):
return json.loads(requests.get(uri).text)
elif re.match("^s3://", uri):
elif is_s3_uri(uri):
u = urlparse(uri)
assert aws_connection
response = aws_connection.get_s3_client().get_object(