Skip to content

Commit

Permalink
Code formatting
Browse files Browse the repository at this point in the history
  • Loading branch information
joelmataKPN committed Jul 9, 2024
1 parent f6025a1 commit 3f0d854
Showing 1 changed file with 10 additions and 4 deletions.
14 changes: 10 additions & 4 deletions metadata-ingestion/src/datahub/ingestion/source/azure/abs_util.py
Original file line number Diff line number Diff line change
Expand Up @@ -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(
Expand Down Expand Up @@ -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(
Expand All @@ -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()
Expand Down Expand Up @@ -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)
Expand Down

0 comments on commit 3f0d854

Please sign in to comment.