Skip to content

Commit bd3703a

Browse files
author
hzhang
committed
add support to ingest from "s3a" protocol
1 parent a8d6c54 commit bd3703a

File tree

1 file changed

+1
-1
lines changed
  • metadata-ingestion/src/datahub/ingestion/source/dbt

1 file changed

+1
-1
lines changed

metadata-ingestion/src/datahub/ingestion/source/dbt/dbt_core.py

+1-1
Original file line numberDiff line numberDiff line change
@@ -488,7 +488,7 @@ def load_file_as_json(
488488
) -> Dict:
489489
if re.match("^https?://", uri):
490490
return json.loads(requests.get(uri).text)
491-
elif re.match("^s3://", uri):
491+
elif re.match("^s3://", uri) or re.match("^s3a://", uri):
492492
u = urlparse(uri)
493493
assert aws_connection
494494
response = aws_connection.get_s3_client().get_object(

0 commit comments

Comments
 (0)