style: apply ruff format to test assertions

Co-Authored-By: bot_apk <apk@cognition.ai>

Author: devin-ai-integration[bot]

unit_tests/sources/streams/concurrent/test_concurrent_read_processor.py

@@ -578,7 +578,10 @@ def test_on_exception_return_trace_message_and_on_stream_complete_return_stream_
         exception_messages = list(handler.on_exception(exception))
         assert len(exception_messages) == 1
         assert "RuntimeError" in exception_messages[0].trace.error.stack_trace
-        assert exception_messages[0].trace.error.message == f"An unexpected error occurred in stream {_STREAM_NAME}: RuntimeError"
+        assert (
+            exception_messages[0].trace.error.message
+            == f"An unexpected error occurred in stream {_STREAM_NAME}: RuntimeError"
+        )
 
         assert list(
             handler.on_partition_complete_sentinel(
@@ -799,7 +802,10 @@ def test_on_exception_non_ate_uses_templated_message_with_correct_failure_type(s
 
         trace_error = exception_messages[0].trace.error
         # User-facing message uses safe template (no raw exception text)
-        assert trace_error.message == f"An unexpected error occurred in stream {_STREAM_NAME}: ValueError"
+        assert (
+            trace_error.message
+            == f"An unexpected error occurred in stream {_STREAM_NAME}: ValueError"
+        )
         # Stack trace comes from the inner exception, not the StreamThreadException wrapper
         assert "ValueError" in trace_error.stack_trace
         assert "StreamThreadException" not in trace_error.stack_trace