From c9319b35dd305d820ce86659cdb9242dc23bedd6 Mon Sep 17 00:00:00 2001 From: Jonny Dixon Date: Wed, 6 Nov 2024 00:56:18 +0000 Subject: [PATCH] Update config.py --- .../datahub/ingestion/source/delta_lake/config.py | 12 ++++++++++-- 1 file changed, 10 insertions(+), 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 index 7a46284e209ac..2c99bbf605a26 100644 --- 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,19 @@ 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 and is_s3_uri(self.base_path or "")) + 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 and is_abs_uri(self.base_path or "")) + 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):