diff --git a/metadata-ingestion/src/datahub/ingestion/source/dbt/dbt_core.py b/metadata-ingestion/src/datahub/ingestion/source/dbt/dbt_core.py index 04de763370..fbb54d211e 100644 --- a/metadata-ingestion/src/datahub/ingestion/source/dbt/dbt_core.py +++ b/metadata-ingestion/src/datahub/ingestion/source/dbt/dbt_core.py @@ -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(