fix: resolve E501 line-too-long linting errors

Author: corpo-iwillspeak

examples/utils/streaming_classify_utils.py

@@ -132,7 +132,7 @@ async def classify_images(
                         received_count,
                         error_count,
                     )
-                    # Explicitly close the async generator to terminate the stream
+                    # Close async generator to terminate stream
                     await results.aclose()
                     break
 

tests/functional/e2e/test_classify_single.py

@@ -62,7 +62,9 @@ async def test_classify_single(
         for label in test_case.expected_output:
             expected = test_case.expected_output[label]
             actual = actual_output[label]
-            assert abs(expected - actual) < FP_ERROR_TOLERANCE, (
-            f"Weight for label '{label}' differs by more than {FP_ERROR_TOLERANCE}: "
-            f"expected={expected}, actual={actual}, diff={abs(expected - actual)}"
+            diff = abs(expected - actual)
+            assert diff < FP_ERROR_TOLERANCE, (
+                f"Weight for label '{label}' differs by more than "
+                f"{FP_ERROR_TOLERANCE}: expected={expected}, actual={actual}, "
+                f"diff={diff}"
             )

tests/functional/test_classify_streaming.py

@@ -59,7 +59,9 @@ async def test_streaming_classify(
     assert sent == received, f"Incomplete: {sent} sent, {received} received"
 
 
-@pytest.mark.skip(reason="Relies on server-side shared queue behavior - needs investigation")
+@pytest.mark.skip(
+    reason="Relies on server-side shared queue behavior - needs investigation"
+)
 @pytest.mark.asyncio
 @pytest.mark.functional
 async def test_streaming_classify_with_reopened_stream(

tests/functional/test_color_channels.py

@@ -72,7 +72,9 @@ async def test_classify_color_channels(
             msg = f"Red image classification error: {red_result.error.message}"
             pytest.fail(msg)
 
-        assert len(red_result.classifications) > 0, "No classifications for red image"
+        assert (
+            len(red_result.classifications) > 0
+        ), "No classifications for red image"
 
         # Test green channel image
         green_image_bytes = create_color_channel_image("green")
@@ -82,7 +84,8 @@ async def test_classify_color_channels(
 
         if green_result.error.code:
             msg = (
-                f"Green image classification error: {green_result.error.message}"
+                "Green image classification error: "
+                f"{green_result.error.message}"
             )
             pytest.fail(msg)
 
@@ -97,7 +100,10 @@ async def test_classify_color_channels(
         blue_result = await client.classify_single(blue_image_data)
 
         if blue_result.error.code:
-            msg = f"Blue image classification error: {blue_result.error.message}"
+            msg = (
+                "Blue image classification error: "
+                f"{blue_result.error.message}"
+            )
             pytest.fail(msg)
 
         assert (
@@ -106,5 +112,9 @@ async def test_classify_color_channels(
 
         # Verify all three images were successfully classified
         assert red_result.classifications, "Red image has no classifications"
-        assert green_result.classifications, "Green image has no classifications"
-        assert blue_result.classifications, "Blue image has no classifications"
+        assert (
+            green_result.classifications
+        ), "Green image has no classifications"
+        assert (
+            blue_result.classifications
+        ), "Blue image has no classifications"

tests/utils/streaming_classify_utils.py

@@ -127,7 +127,7 @@ async def classify_images(
                         received_count,
                         error_count,
                     )
-                    # Explicitly close the async generator to terminate the stream
+                    # Close async generator to terminate stream
                     await results.aclose()
                     break