Formatting

Author: AsafMah

.github/workflows/build.yml

@@ -43,16 +43,12 @@ jobs:
           APPLICATION_INSIGHTS_ENGINE_CONNECTION_STRING: https://ade.applicationinsights.io/subscriptions/12534eb3-8109-4d84-83ad-576c0d5e1d06/resourcegroups/clients_e2e_test/providers/microsoft.insights/components/kusto-e2e-app-insights
           APPLICATION_INSIGHTS_TEST_DATABASE: kusto-e2e-app-insights
         run: uvx poe test --ci
-      
-      #      todo: re-enable on a different PR
-      #      - name: "Run Ruff Formatter"
-      #        id: ruff-formatter
-      #        uses: astral-sh/ruff-action@v3
-      #        with:
-      #          args: "format --diff"
-      #          
-      #      - name: "Run Ruff Linter"
-      #        run: ruff check --diff        
+
+      - name: "Run Ruff Formatter"
+        run: uvx poe check-format
+
+      - name: "Run Ruff Linter"
+        run: uvx poe lint
 
       - name: Upload Unit Test Results
         if: always()

azure-kusto-data/azure/kusto/data/exceptions.py

@@ -19,12 +19,10 @@ class KustoError(Exception):
     """Base class for all exceptions raised by the Kusto Python Client Libraries."""
 
 
-class KustoStreamingQueryError(KustoError):
-    ...
+class KustoStreamingQueryError(KustoError): ...
 
 
-class KustoTokenParsingError(KustoStreamingQueryError):
-    ...
+class KustoTokenParsingError(KustoStreamingQueryError): ...
 
 
 SEMANTIC_ERROR_STRING = "Semantic error:"

azure-kusto-data/azure/kusto/data/kusto_trusted_endpoints.py

@@ -95,7 +95,7 @@ def validate_hostname_is_trusted(self, hostname: str, login_endpoint: str):
             return
 
         raise KustoClientInvalidConnectionStringException(
-            f"Can't communicate with '{hostname}' as this hostname is currently not trusted; please see " f"https://aka.ms/kustotrustedendpoints"
+            f"Can't communicate with '{hostname}' as this hostname is currently not trusted; please see https://aka.ms/kustotrustedendpoints"
         )
 
     def set_override_policy(self, matcher):

azure-kusto-data/tests/aio/test_kusto_client.py

@@ -1,4 +1,5 @@
 """Tests for KustoClient."""
+
 import json
 import sys
 from unittest.mock import patch

azure-kusto-data/tests/sample.py

@@ -1,4 +1,4 @@
-# Copyright (c) Microsoft Corporation.
+# Copyright (c) Microsoft Corporation.
 # Licensed under the MIT License
 """A simple example how to use KustoClient."""
 

azure-kusto-data/tests/test_kusto_connection_string_builder.py

@@ -81,16 +81,18 @@ def test_aad_app(self):
             assert kcsb.application_client_id == uuid
             assert kcsb.application_key == key
             assert kcsb.authority_id == "microsoft.com"
-            assert repr(
-                kcsb
-            ) == "Data Source=localhost;Initial Catalog=NetDefaultDB;AAD Federated Security=True;Application Client Id={0};Application Key={1};Authority Id={2}".format(
-                uuid, key, "microsoft.com"
+            assert (
+                repr(kcsb)
+                == "Data Source=localhost;Initial Catalog=NetDefaultDB;AAD Federated Security=True;Application Client Id={0};Application Key={1};Authority Id={2}".format(
+                    uuid, key, "microsoft.com"
+                )
             )
 
-            assert str(
-                kcsb
-            ) == "Data Source=localhost;Initial Catalog=NetDefaultDB;AAD Federated Security=True;Application Client Id={0};Application Key={1};Authority Id={2}".format(
-                uuid, self.PASSWORDS_REPLACEMENT, "microsoft.com"
+            assert (
+                str(kcsb)
+                == "Data Source=localhost;Initial Catalog=NetDefaultDB;AAD Federated Security=True;Application Client Id={0};Application Key={1};Authority Id={2}".format(
+                    uuid, self.PASSWORDS_REPLACEMENT, "microsoft.com"
+                )
             )
 
     def test_aad_user(self):

azure-kusto-ingest/azure/kusto/ingest/exceptions.py

@@ -37,7 +37,6 @@ def __init__(self, expected_service_type, actual_service_type, suggested_endpoin
 
 
 class KustoQueueError(KustoClientError):
-
     """Raised when not succeeding to upload message to queue in all retries"""
 
     def __init__(self):

azure-kusto-ingest/tests/test_kusto_streaming_ingest_client.py

@@ -194,9 +194,9 @@ def test_streaming_ingest_from_stream(self, ingest_client_class):
         assert result.status == IngestionStatus.SUCCESS
 
     def test_client_uri_from_query_endpoint(self):
-        assert (
-            KustoStreamingIngestClient("https://somecluster.kusto.windows.net")._kusto_client._kusto_cluster == "https://somecluster.kusto.windows.net/"
-        ), "Client URI was not extracted correctly from query endpoint"
+        assert KustoStreamingIngestClient("https://somecluster.kusto.windows.net")._kusto_client._kusto_cluster == "https://somecluster.kusto.windows.net/", (
+            "Client URI was not extracted correctly from query endpoint"
+        )
 
     def test_client_uri_from_ingestion_endpoint(self):
         assert (

pyproject.toml

@@ -58,7 +58,7 @@ sync = "uv sync --all-packages --all-extras --dev --locked"
 build = "uv build --all-packages"
 format = "ruff format"
 check-format = "ruff format --diff"
-lint = "ruff check"
+lint = "ruff check --diff"
 lint-fix = "ruff check --fix"
 lint-fix-unsafe = "ruff check --fix --unsafe-fixes"
 show-version = "uv version"