Update config.py

datahub-project · Nov 6, 2024 · 83fe86c · 83fe86c
1 parent 2575a54
commit 83fe86c
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/metadata-ingestion/src/datahub/ingestion/source/delta_lake/config.py b/metadata-ingestion/src/datahub/ingestion/source/delta_lake/config.py
@@ -91,11 +91,11 @@ class DeltaLakeSourceConfig(PlatformInstanceConfigMixin, EnvConfigMixin):
 
     @cached_property
     def is_s3(self) -> bool:
-        return bool(self.s3 is not None and self.s3.aws_config is not None)
+        return bool(self.s3 is not None and self.s3.aws_config is not None and is_s3_uri(self.base_path or ""))
 
     @cached_property
     def is_azure(self) -> bool:
-        return bool(self.azure is not None and self.azure.azure_config is not None)
+        return bool(self.azure is not None and self.azure.azure_config is not None and is_abs_uri(self.base_path or ""))
 
     @cached_property
     def complete_path(self):