black

Author: m-kovalsky

src/sempy_labs/directlake/_dl_helper.py

@@ -225,7 +225,10 @@ def get_direct_lake_source(
     (workspace_name, workspace_id) = resolve_workspace_name_and_id(workspace)
     sql_endpoint_id = get_direct_lake_sql_endpoint(dataset=dataset, workspace=workspace)
     dfI = fabric.list_items(workspace=workspace)
-    dfI_filt = dfI[(dfI["Id"] == sql_endpoint_id) & (dfI["Type"].isin(["SQLEndpoint","Warehouse"]))]
+    dfI_filt = dfI[
+        (dfI["Id"] == sql_endpoint_id)
+        & (dfI["Type"].isin(["SQLEndpoint", "Warehouse"]))
+    ]
 
     artifact_type, artifact_name, artifact_id = None, None, None
 

src/sempy_labs/lakehouse/_helper.py

@@ -68,10 +68,17 @@ def read_vorder_tag(delta_log_path):
         latest_file = os.path.join(delta_log_path, json_files[0])
 
         with open(latest_file, "r") as f:
-            all_data = [json.loads(line) for line in f if line.strip()]  # one dict per line
+            all_data = [
+                json.loads(line) for line in f if line.strip()
+            ]  # one dict per line
             for data in all_data:
-                if 'metaData' in data:
-                    return data.get('metaData', {}).get('configuration', {}).get('delta.parquet.vorder.enabled', 'false') == 'true'
+                if "metaData" in data:
+                    return (
+                        data.get("metaData", {})
+                        .get("configuration", {})
+                        .get("delta.parquet.vorder.enabled", "false")
+                        == "true"
+                    )
 
             # If no metaData, fall back to commitInfo
             for data in all_data:

src/sempy_labs/lakehouse/_lakehouse.py

@@ -245,7 +245,9 @@ def is_valid_format(time_string):
         client="fabric_sp",
     )
 
-    print(f"{icons.in_progress} The table maintenance job for the '{table_name}' table in the '{lakehouse_name}' lakehouse within the '{workspace_name}' workspace has been initiated.")
+    print(
+        f"{icons.in_progress} The table maintenance job for the '{table_name}' table in the '{lakehouse_name}' lakehouse within the '{workspace_name}' workspace has been initiated."
+    )
 
     status_url = response.headers.get("Location").split("fabric.microsoft.com")[1]
     status = None