fixing pylint

Author: lusu-msft

sdk/agentserver/azure-ai-agentserver-agentframework/azure/ai/agentserver/agentframework/agent_framework.py

@@ -1,7 +1,7 @@
 # ---------------------------------------------------------
 # Copyright (c) Microsoft Corporation. All rights reserved.
 # ---------------------------------------------------------
-# pylint: disable=logging-fstring-interpolation,no-name-in-module
+# pylint: disable=logging-fstring-interpolation,no-name-in-module,no-member
 from __future__ import annotations
 
 import os
@@ -239,7 +239,9 @@ async def stream_updates():
                         #         logger.debug("Agent streaming iterator finished (StopAsyncIteration)")
                         #         break
                         #     except asyncio.TimeoutError:
-                        #         logger.warning("Streaming idle timeout reached (%.1fs); terminating stream.", timeout_s)
+                        #         logger.warning(
+                        #             "Streaming idle timeout reached (%.1fs); terminating stream.", timeout_s
+                        #         )
                         #         for ev in streaming_converter.completion_events():
                         #             yield ev
                         #         return

sdk/agentserver/azure-ai-agentserver-agentframework/azure/ai/agentserver/agentframework/models/agent_framework_output_streaming_converter.py

@@ -228,16 +228,15 @@ async def convert_contents(self, contents: AsyncIterable[FunctionResultContent])
     def _to_output(cls, result: Any) -> str:
         if isinstance(result, str):
             return result
-        elif isinstance(result, list):
+        if isinstance(result, list):
             text = []
             for item in result:
                 if isinstance(item, BaseContent):
                     text.append(item.to_dict())
                 else:
                     text.append(str(item))
             return json.dumps(text)
-        else:
-            return ""
+        return ""
 
 
 class AgentFrameworkOutputStreamingConverter:
@@ -281,7 +280,9 @@ async def convert(self, updates: AsyncIterable[AgentRunResponseUpdate]) -> Async
             response=created_response,
         )
 
-        is_changed = lambda a, b: a is not None and b is not None and a.message_id != b.message_id
+        is_changed = (
+            lambda a, b: a is not None and b is not None and a.message_id != b.message_id
+        )
         async for group in chunk_on_change(updates, is_changed):
             has_value, first, contents = await peek(self._read_updates(group))
             if not has_value: