@@ -100,7 +100,7 @@ def extract_document_info(nodes: List[NodeWithScore]):
100100
101101
102102def build_message_dict (message : ChatMessage ):
103- message_dict = {
103+ message_dict : GenerationMessage = {
104104 "role" : convert_message_role (message .role ),
105105 "content" : message .content ,
106106 }
@@ -144,8 +144,8 @@ def extract_query(x: Union[str, QueryBundle]):
144144class LiteralEventHandler (BaseEventHandler ):
145145 """This class handles events coming from LlamaIndex."""
146146
147- _client : "LiteralClient" = PrivateAttr (... )
148- _span_handler : "LiteralSpanHandler" = PrivateAttr (... )
147+ _client : "LiteralClient" = PrivateAttr ()
148+ _span_handler : "LiteralSpanHandler" = PrivateAttr ()
149149 runs : Dict [str , List [Step ]] = {}
150150 streaming_run_ids : List [str ] = []
151151 _standalone_step_id : Optional [str ] = None
@@ -163,21 +163,18 @@ def __init__(
163163 object .__setattr__ (self , "_client" , literal_client )
164164 object .__setattr__ (self , "_span_handler" , llama_index_span_handler )
165165
166- def _convert_message (
167- self ,
168- message : ChatMessage ,
169- ):
166+ def _convert_message (self , message : ChatMessage ):
170167 tool_calls = message .additional_kwargs .get ("tool_calls" )
171- msg = GenerationMessage (
172- name = getattr (message , "name" , None ),
173- role = convert_message_role (message .role ),
174- content = "" ,
175- )
176-
177- msg [ "content" ] = message . content
178-
179- if tool_calls :
180- msg [ "tool_calls" ] = [ tool_call . to_dict () for tool_call in tool_calls ]
168+ msg : GenerationMessage = {
169+ " name" : getattr (message , "name" , None ),
170+ " role" : convert_message_role (message .role ),
171+ " content" : message . content ,
172+ "tool_calls" : (
173+ [ tool_call . to_dict () for tool_call in tool_calls ]
174+ if tool_calls
175+ else None
176+ ),
177+ }
181178
182179 return msg
183180
@@ -238,7 +235,7 @@ def handle(self, event: BaseEvent, **kwargs) -> None:
238235 thread_id = thread_id ,
239236 content = query ,
240237 )
241-
238+
242239 # Retrieval wraps the Embedding step in LlamaIndex
243240 if isinstance (event , RetrievalStartEvent ):
244241 run = self ._client .start_step (
0 commit comments