Apply black formatting to examples and test files

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>

Author: Abel Milash

examples/aio/advanced/alternate_keys_upsert.py

@@ -27,6 +27,7 @@
 from PowerPlatform.Dataverse.aio.async_client import AsyncDataverseClient
 from PowerPlatform.Dataverse.models.upsert import UpsertItem
 from pathlib import Path
+
 sys.path.insert(0, str(Path(__file__).resolve().parents[1]))
 from _auth import AsyncInteractiveBrowserCredential
 

examples/aio/advanced/batch.py

@@ -19,6 +19,7 @@
 import sys
 
 from pathlib import Path
+
 sys.path.insert(0, str(Path(__file__).resolve().parents[1]))
 from _auth import AsyncInteractiveBrowserCredential
 from PowerPlatform.Dataverse.aio.async_client import AsyncDataverseClient
@@ -61,7 +62,9 @@ async def main():
 
             result = await batch.execute()
 
-            print(f"[OK] Total: {len(result.responses)}, Succeeded: {len(result.succeeded)}, Failed: {len(result.failed)}")
+            print(
+                f"[OK] Total: {len(result.responses)}, Succeeded: {len(result.succeeded)}, Failed: {len(result.failed)}"
+            )
             for guid in result.entity_ids:
                 print(f"[OK] Created: {guid}")
             for item in result.failed:

examples/aio/advanced/dataframe_operations.py

@@ -20,6 +20,7 @@
 
 import pandas as pd
 from pathlib import Path
+
 sys.path.insert(0, str(Path(__file__).resolve().parents[1]))
 from _auth import AsyncInteractiveBrowserCredential
 
@@ -89,12 +90,7 @@ async def _run_walkthrough(client):
     print("2. Query records as a DataFrame")
     print("-" * 60)
 
-    result = await (
-        client.query.builder(table)
-        .select(*select_cols)
-        .where(raw(test_filter))
-        .execute()
-    )
+    result = await client.query.builder(table).select(*select_cols).where(raw(test_filter)).execute()
     df_all = result.to_dataframe()
     print(f"[OK] Got {len(df_all)} records in one DataFrame")
     print(f"  Columns: {list(df_all.columns)}")
@@ -105,13 +101,7 @@ async def _run_walkthrough(client):
     print("3. Limit results with top")
     print("-" * 60)
 
-    result_top2 = await (
-        client.query.builder(table)
-        .select(*select_cols)
-        .where(raw(test_filter))
-        .top(2)
-        .execute()
-    )
+    result_top2 = await client.query.builder(table).select(*select_cols).where(raw(test_filter)).top(2).execute()
     df_top2 = result_top2.to_dataframe()
     print(f"[OK] Got {len(df_top2)} records with top=2")
     print(f"{df_top2.to_string(index=False)}")
@@ -123,12 +113,7 @@ async def _run_walkthrough(client):
 
     first_id = new_accounts["accountid"].iloc[0]
     print(f"  Fetching record {first_id}...")
-    result_single = await (
-        client.query.builder(table)
-        .select(*select_cols)
-        .where(col("accountid") == first_id)
-        .execute()
-    )
+    result_single = await client.query.builder(table).select(*select_cols).where(col("accountid") == first_id).execute()
     single = result_single.to_dataframe()
     print(f"[OK] Single record DataFrame:\n{single.to_string(index=False)}")
 
@@ -143,9 +128,7 @@ async def _run_walkthrough(client):
     print("[OK] Updated 3 records")
 
     # Verify the updates
-    result_verified = await (
-        client.query.builder(table).select(*select_cols).where(raw(test_filter)).execute()
-    )
+    result_verified = await client.query.builder(table).select(*select_cols).where(raw(test_filter)).execute()
     verified = result_verified.to_dataframe()
     print(f"  Verified:\n{verified.to_string(index=False)}")
 
@@ -161,9 +144,7 @@ async def _run_walkthrough(client):
     print("[OK] Broadcast update complete")
 
     # Verify all records have the same websiteurl
-    result_bc = await (
-        client.query.builder(table).select(*select_cols).where(raw(test_filter)).execute()
-    )
+    result_bc = await client.query.builder(table).select(*select_cols).where(raw(test_filter)).execute()
     print(f"  Verified:\n{result_bc.to_dataframe().to_string(index=False)}")
 
     # Default: NaN/None fields are skipped (not overridden on server)
@@ -174,9 +155,7 @@ async def _run_walkthrough(client):
         ]
     )
     await client.dataframe.update(table, sparse_df, id_column="accountid")
-    result_sparse = await (
-        client.query.builder(table).select(*select_cols).where(raw(test_filter)).execute()
-    )
+    result_sparse = await client.query.builder(table).select(*select_cols).where(raw(test_filter)).execute()
     print(
         f"  Verified (Contoso telephone1 updated, websiteurl unchanged):\n"
         f"{result_sparse.to_dataframe().to_string(index=False)}"
@@ -186,13 +165,8 @@ async def _run_walkthrough(client):
     print("\n  Clearing websiteurl for Contoso with clear_nulls=True...")
     clear_df = pd.DataFrame([{"accountid": new_accounts["accountid"].iloc[0], "websiteurl": None}])
     await client.dataframe.update(table, clear_df, id_column="accountid", clear_nulls=True)
-    result_clear = await (
-        client.query.builder(table).select(*select_cols).where(raw(test_filter)).execute()
-    )
-    print(
-        f"  Verified (Contoso websiteurl should be empty):\n"
-        f"{result_clear.to_dataframe().to_string(index=False)}"
-    )
+    result_clear = await client.query.builder(table).select(*select_cols).where(raw(test_filter)).execute()
+    print(f"  Verified (Contoso websiteurl should be empty):\n" f"{result_clear.to_dataframe().to_string(index=False)}")
 
     # -- 7. Delete records by passing a Series of GUIDs ------------
     print("\n" + "-" * 60)
@@ -204,9 +178,7 @@ async def _run_walkthrough(client):
     print(f"[OK] Deleted {len(new_accounts)} records")
 
     # Verify deletions -- filter for our tagged records should return 0
-    result_remaining = await (
-        client.query.builder(table).select(*select_cols).where(raw(test_filter)).execute()
-    )
+    result_remaining = await client.query.builder(table).select(*select_cols).where(raw(test_filter)).execute()
     remaining = result_remaining.to_dataframe()
     print(f"  Verified: {len(remaining)} test records remaining (expected 0)")
 

examples/aio/advanced/datascience_risk_assessment.py

@@ -51,6 +51,7 @@
 
 import numpy as np
 import pandas as pd
+
 sys.path.insert(0, str(Path(__file__).resolve().parents[1]))
 from _auth import AsyncInteractiveBrowserCredential
 

examples/aio/advanced/fetchxml.py

@@ -31,6 +31,7 @@
 import sys
 
 from pathlib import Path
+
 sys.path.insert(0, str(Path(__file__).resolve().parents[1]))
 from _auth import AsyncInteractiveBrowserCredential
 from PowerPlatform.Dataverse.aio.async_client import AsyncDataverseClient
@@ -193,13 +194,55 @@ async def _run_examples(client):
 
     log_call(f"await client.records.create('{task_table}', [...])")
     tasks = [
-        {"new_Title": "Design mockups",      "new_Hours": 8,  "new_Done": True,  "new_Priority": 2, "new_ProjectId@odata.bind": f"/{project_set}({project_ids[0]})"},
-        {"new_Title": "Write unit tests",    "new_Hours": 12, "new_Done": False, "new_Priority": 3, "new_ProjectId@odata.bind": f"/{project_set}({project_ids[0]})"},
-        {"new_Title": "Code review",         "new_Hours": 3,  "new_Done": True,  "new_Priority": 1, "new_ProjectId@odata.bind": f"/{project_set}({project_ids[1]})"},
-        {"new_Title": "Deploy to staging",   "new_Hours": 5,  "new_Done": False, "new_Priority": 3, "new_ProjectId@odata.bind": f"/{project_set}({project_ids[1]})"},
-        {"new_Title": "Update docs",         "new_Hours": 4,  "new_Done": True,  "new_Priority": 1, "new_ProjectId@odata.bind": f"/{project_set}({project_ids[2]})"},
-        {"new_Title": "Performance tuning",  "new_Hours": 10, "new_Done": False, "new_Priority": 2, "new_ProjectId@odata.bind": f"/{project_set}({project_ids[3]})"},
-        {"new_Title": "Security audit",      "new_Hours": 6,  "new_Done": False, "new_Priority": 3, "new_ProjectId@odata.bind": f"/{project_set}({project_ids[4]})"},
+        {
+            "new_Title": "Design mockups",
+            "new_Hours": 8,
+            "new_Done": True,
+            "new_Priority": 2,
+            "new_ProjectId@odata.bind": f"/{project_set}({project_ids[0]})",
+        },
+        {
+            "new_Title": "Write unit tests",
+            "new_Hours": 12,
+            "new_Done": False,
+            "new_Priority": 3,
+            "new_ProjectId@odata.bind": f"/{project_set}({project_ids[0]})",
+        },
+        {
+            "new_Title": "Code review",
+            "new_Hours": 3,
+            "new_Done": True,
+            "new_Priority": 1,
+            "new_ProjectId@odata.bind": f"/{project_set}({project_ids[1]})",
+        },
+        {
+            "new_Title": "Deploy to staging",
+            "new_Hours": 5,
+            "new_Done": False,
+            "new_Priority": 3,
+            "new_ProjectId@odata.bind": f"/{project_set}({project_ids[1]})",
+        },
+        {
+            "new_Title": "Update docs",
+            "new_Hours": 4,
+            "new_Done": True,
+            "new_Priority": 1,
+            "new_ProjectId@odata.bind": f"/{project_set}({project_ids[2]})",
+        },
+        {
+            "new_Title": "Performance tuning",
+            "new_Hours": 10,
+            "new_Done": False,
+            "new_Priority": 2,
+            "new_ProjectId@odata.bind": f"/{project_set}({project_ids[3]})",
+        },
+        {
+            "new_Title": "Security audit",
+            "new_Hours": 6,
+            "new_Done": False,
+            "new_Priority": 3,
+            "new_ProjectId@odata.bind": f"/{project_set}({project_ids[4]})",
+        },
     ]
     task_ids = await backoff(lambda: client.records.create(task_table, tasks))
     print(f"[OK] Seeded {len(task_ids)} tasks")

examples/aio/advanced/file_upload.py

@@ -21,6 +21,7 @@
 from pathlib import Path
 
 from PowerPlatform.Dataverse.aio.async_client import AsyncDataverseClient
+
 sys.path.insert(0, str(Path(__file__).resolve().parents[1]))
 from _auth import AsyncInteractiveBrowserCredential
 
@@ -111,6 +112,7 @@ async def ensure_table(client) -> dict:
 
 # --- Main ---
 
+
 async def main():
     entered = input("Enter Dataverse org URL (e.g. https://yourorg.crm.dynamics.com): ").strip()
     if not entered:
@@ -271,7 +273,9 @@ async def main():
                         content_chunk = await resp.read() if hasattr(resp, "read") else (resp.content or b"")
 
                     dst_hash_chunk = hashlib.sha256(content_chunk).hexdigest() if content_chunk else None
-                    hash_match_chunk = (dst_hash_chunk == src_hash_chunk) if (dst_hash_chunk and src_hash_chunk) else None
+                    hash_match_chunk = (
+                        (dst_hash_chunk == src_hash_chunk) if (dst_hash_chunk and src_hash_chunk) else None
+                    )
                     print(
                         {
                             "chunk_source_size": src_size_chunk,

examples/aio/advanced/prodev_output/projects.csv

@@ -0,0 +1,5 @@
+new_demoprojectce00be_budget,new_demoprojectce00be_status,new_name,new_demoprojectce00beid
+250000.0,Active,Cloud Migration,33f255c6-f34e-f111-bec3-6045bd0a9d1e
+500000.0,Active,ERP Upgrade,34f255c6-f34e-f111-bec3-6045bd0a9d1e
+150000.0,Planning,POS Modernization,35f255c6-f34e-f111-bec3-6045bd0a9d1e
+180000.0,Active,Data Analytics Platform,36f255c6-f34e-f111-bec3-6045bd0a9d1e

examples/aio/advanced/prodev_output/single_customer.csv

@@ -0,0 +1,2 @@
+modifiedon,_owninguser_value,new_democustomerce00beid,overriddencreatedon,importsequencenumber,_modifiedonbehalfby_value,new_democustomerce00be_email,new_democustomerce00be_revenue,statecode,new_democustomerce00be_industry,versionnumber,utcconversiontimezonecode,_createdonbehalfby_value,_modifiedby_value,new_name,createdon,_owningbusinessunit_value,statuscode,_owningteam_value,_createdby_value,_ownerid_value,timezoneruleversionnumber
+2026-05-13T17:47:23Z,5b9afa50-6d10-f111-8342-6045bd027886,27f255c6-f34e-f111-bec3-6045bd0a9d1e,,,,info@contoso.com,5000000.0,0,Technology,6454305,,,5b9afa50-6d10-f111-8342-6045bd027886,Contoso Ltd,2026-05-13T17:47:23Z,18efff4a-6d10-f111-8342-6045bd027886,1,,5b9afa50-6d10-f111-8342-6045bd027886,5b9afa50-6d10-f111-8342-6045bd027886,

examples/aio/advanced/prodev_output/tasks.csv

@@ -0,0 +1,7 @@
+new_demotaskce00be_estimatedhours,new_demotaskce00be_status,new_demotaskce00be_priority,new_name,new_demotaskce00beid
+40.0,In Progress,1,Infrastructure Setup,68674ecc-f34e-f111-bec3-6045bd0a9d1e
+20.0,Not Started,2,Data Assessment,69674ecc-f34e-f111-bec3-6045bd0a9d1e
+60.0,Not Started,1,Testing & QA,6a674ecc-f34e-f111-bec3-6045bd0a9d1e
+30.0,Complete,1,Requirements Gathering,6b674ecc-f34e-f111-bec3-6045bd0a9d1e
+80.0,In Progress,1,Development Sprint 1,6c674ecc-f34e-f111-bec3-6045bd0a9d1e
+16.0,Not Started,3,User Training,6d674ecc-f34e-f111-bec3-6045bd0a9d1e

examples/aio/advanced/prodev_quick_start.py

@@ -33,6 +33,7 @@
 warnings.filterwarnings("ignore", message="response_mode=.*form_post", category=UserWarning)
 
 import pandas as pd
+
 sys.path.insert(0, str(Path(__file__).resolve().parents[1]))
 from _auth import AsyncInteractiveBrowserCredential
 
@@ -384,9 +385,7 @@ async def step4_query_and_analyze(client, customer_ids, primary_name_col, primar
 
     # Fetch single customer record by ID
     first_id = customer_ids.iloc[0]
-    single_result = await (
-        client.query.builder(TABLE_CUSTOMER).where(col(primary_id_col) == first_id).execute()
-    )
+    single_result = await client.query.builder(TABLE_CUSTOMER).where(col(primary_id_col) == first_id).execute()
     single = single_result.to_dataframe()
     print(f"\n  Single customer record (by ID):")
     print(f"{single.to_string(index=False)}")