lint

Signed-off-by: Filinto Duran <[email protected]>

Author: filintod

dapr/aio/clients/grpc/client.py

@@ -105,8 +105,14 @@
     StartWorkflowResponse,
     TopicEventResponse,
 )
-from dapr.clients.grpc.conversation import ConversationResult, ConversationResultAlpha2Message, \
-    ConversationResultAlpha2Choices, ConversationResultAlpha2, ConversationResponse, ConversationResponseAlpha2
+from dapr.clients.grpc.conversation import (
+    ConversationResult,
+    ConversationResultAlpha2Message,
+    ConversationResultAlpha2Choices,
+    ConversationResultAlpha2,
+    ConversationResponse,
+    ConversationResponseAlpha2,
+)
 
 
 class DaprGrpcClientAsync:

dapr/clients/grpc/_conversation_helpers.py

@@ -502,15 +502,6 @@ def function_to_json_schema(
     # Extract parameter descriptions from docstring
     param_descriptions = _extract_docstring_args(func)
 
-    # Get function description
-    if description is None:
-        docstring = inspect.getdoc(func)
-        if docstring:
-            # Use first line of docstring as description
-            description = docstring.split('\n')[0].strip()
-        else:
-            description = f'Function {func.__name__}'
-
     # Build JSON schema
     schema: Dict[str, Any] = {'type': 'object', 'properties': {}, 'required': []}
 

dapr/clients/grpc/client.py

@@ -1882,7 +1882,9 @@ def converse_alpha2(
                         if not tool_call.id:
                             tool_call.id = _generate_unique_tool_call_id()
                         tool_calls.append(
-                            conversation.ConversationToolCalls(id=tool_call.id, function=function_call)
+                            conversation.ConversationToolCalls(
+                                id=tool_call.id, function=function_call
+                            )
                         )
 
                     result_message = conversation.ConversationResultAlpha2Message(
@@ -1899,7 +1901,9 @@ def converse_alpha2(
 
                 outputs.append(conversation.ConversationResultAlpha2(choices=choices))
 
-            return conversation.ConversationResponseAlpha2(context_id=response.context_id, outputs=outputs)
+            return conversation.ConversationResponseAlpha2(
+                context_id=response.context_id, outputs=outputs
+            )
         except RpcError as err:
             raise DaprGrpcError(err) from err
 

dapr/clients/grpc/conversation.py

@@ -299,6 +299,7 @@ def from_function(cls, func: Callable, register: bool = True) -> 'ConversationTo
             register_tool(c.name, ConversationTools(function=c, backend=FunctionBackend(func)))
         return c
 
+
 # ------------------------------------------------------------------------------------------------
 # Response Classes
 # ------------------------------------------------------------------------------------------------
@@ -355,7 +356,7 @@ def to_assistant_messages(self) -> List[ConversationMessage]:
         """Helper to convert to Assistant messages and makes it easy to use in multi-turn conversations."""
 
         def convert_llm_response_to_conversation_input(
-                result_message: ConversationResultAlpha2Message,
+            result_message: ConversationResultAlpha2Message,
         ) -> ConversationMessage:
             """Convert ConversationResultMessage (from LLM response) to ConversationMessage."""
 
@@ -369,9 +370,7 @@ def convert_llm_response_to_conversation_input(
 
             # Create an assistant message (since LLM responses are always assistant messages)
             return ConversationMessage(
-                of_assistant=ConversationMessageOfAssistant(
-                    content=content, tool_calls=tool_calls
-                )
+                of_assistant=ConversationMessageOfAssistant(content=content, tool_calls=tool_calls)
             )
 
         """Convert the outputs to a list of ConversationInput."""
@@ -385,6 +384,7 @@ def convert_llm_response_to_conversation_input(
 
         return assistant_messages
 
+
 # ------------------------------------------------------------------------------------------------
 # Tool Helpers
 # ------------------------------------------------------------------------------------------------
@@ -481,6 +481,7 @@ class ConversationTools:
     backend: Optional[ToolBackend] = None
 
     def invoke(self, params: Params = None) -> Any:
+        """execute the tool with params"""
         if not self.backend:
             raise conv_helpers.ToolExecutionError('Tool backend not set')
         return self.backend.invoke(self.function, params)