Fix ruff/codex errors

Signed-off-by: Aleksandr Samarin <[email protected]>

Author: astralord

vllm/entrypoints/openai/serving_chat.py

@@ -6,7 +6,7 @@
 import time
 from collections.abc import AsyncGenerator, AsyncIterator
 from collections.abc import Sequence as GenericSequence
-from typing import Callable, Final, Optional, Union
+from typing import Any, Callable, Final, Optional, Union
 
 import jinja2
 import partial_json_parser
@@ -790,11 +790,10 @@ async def chat_completion_stream_generator(
 
                     if self.use_harmony:
                         # Group consecutive tokens with same channel/recipient
-                        groups = []
+                        groups: list[dict[str, str]] = []
                         for channel, recipient, text in token_states:
-                            if not text:
-                                continue
-                            if groups and groups[-1]['channel'] == channel and groups[-1]['recipient'] == recipient:
+                            if (groups and groups[-1]['channel'] == channel
+                                    and groups[-1]['recipient'] == recipient):
                                 groups[-1]['text'] += text
                             else:
                                 groups.append({
@@ -849,14 +848,16 @@ async def chat_completion_stream_generator(
                                         index=next_tool_index,
                                     ))
                                     prev_recipient = group_recipient
-                                    # Increment for any subsequent new tool calls in this chunk
+                                    # Increment for subsequent new tool calls
                                     next_tool_index += 1
 
                                 if group_text:
                                     # Stream arguments for the ongoing tool call
-                                    # The current call index is next_tool_index - 1 if we just
-                                    # opened it, OR base_index if continuing from prev chunk
-                                    tool_call_index = next_tool_index - 1 if next_tool_index > base_index else base_index
+                                    # Use next_tool_index - 1 if we opened a call
+                                    # this chunk, else base_index for ongoing
+                                    tool_call_index = (next_tool_index - 1
+                                                       if next_tool_index > base_index
+                                                       else base_index)
                                     tool_messages.append(DeltaToolCall(
                                         index=tool_call_index,
                                         function=DeltaFunctionCall(
@@ -865,7 +866,7 @@ async def chat_completion_stream_generator(
 
                         # Combine all non-empty fields into a single message
                         if combined_content or combined_reasoning or tool_messages:
-                            delta_kwargs = {}
+                            delta_kwargs: dict[str, Any] = {}
                             if combined_content:
                                 delta_kwargs['content'] = combined_content
                             if combined_reasoning:
@@ -1117,7 +1118,8 @@ async def chat_completion_stream_generator(
                         if delta_message.content:
                             delta_content_parts.append(delta_message.content)
                         if delta_message.reasoning_content:
-                            delta_content_parts.append(f"[reasoning: {delta_message.reasoning_content}]")
+                            reasoning = delta_message.reasoning_content
+                            delta_content_parts.append(f"[reasoning: {reasoning}]")
                         if delta_message.tool_calls:
                             tool_args = "".join(
                                 tc.function.arguments