From 3f0d854a4b244752ea05d10eaf5036ac3bc7fcbd Mon Sep 17 00:00:00 2001 From: joelmata Date: Tue, 9 Jul 2024 10:18:46 +0200 Subject: [PATCH] Code formatting --- .../src/datahub/ingestion/source/azure/abs_util.py | 14 ++++++++++---- 1 file changed, 10 insertions(+), 4 deletions(-) diff --git a/metadata-ingestion/src/datahub/ingestion/source/azure/abs_util.py b/metadata-ingestion/src/datahub/ingestion/source/azure/abs_util.py index 8e195ca41648e8..3adcd3b656d54f 100644 --- a/metadata-ingestion/src/datahub/ingestion/source/azure/abs_util.py +++ b/metadata-ingestion/src/datahub/ingestion/source/azure/abs_util.py @@ -83,7 +83,9 @@ def get_abs_properties( use_abs_blob_properties: Optional[bool] = False, ) -> Dict[str, str]: if azure_config is None: - raise ValueError("Azure configuration is not provided. Cannot retrieve container client.") + raise ValueError( + "Azure configuration is not provided. Cannot retrieve container client." + ) blob_service_client = azure_config.get_blob_service_client() container_client = blob_service_client.get_container_client( @@ -170,7 +172,7 @@ def create_properties( prefix=f"{prefix}_{key}", custom_properties=custom_properties, resource_name=resource_name, - json_properties=json_properties + json_properties=json_properties, ) else: custom_properties = add_property( @@ -195,7 +197,9 @@ def get_abs_tags( ) -> Optional[GlobalTagsClass]: # Todo add the service_client, when building out this get_abs_tags if azure_config is None: - raise ValueError("Azure configuration is not provided. Cannot retrieve container client.") + raise ValueError( + "Azure configuration is not provided. Cannot retrieve container client." + ) tags_to_add: List[str] = [] blob_service_client = azure_config.get_blob_service_client() @@ -240,7 +244,9 @@ def list_folders( container_name: str, prefix: str, azure_config: Optional[AzureConnectionConfig] ) -> Iterable[str]: if azure_config is None: - raise ValueError("Azure configuration is not provided. Cannot retrieve container client.") + raise ValueError( + "Azure configuration is not provided. Cannot retrieve container client." + ) abs_blob_service_client = azure_config.get_blob_service_client() container_client = abs_blob_service_client.get_container_client(container_name)