1010from ldai .providers .types import LDAIMetrics
1111
1212from ldai_langchain .langchain_helper import (
13+ create_langchain_model ,
1314 get_ai_metrics_from_response ,
1415 get_ai_usage_from_response ,
1516 get_tool_calls_from_response ,
@@ -51,7 +52,6 @@ async def run(self, input: Any) -> AgentGraphResult:
5152 tracker = self ._graph .get_tracker ()
5253 start_ns = time .perf_counter_ns ()
5354 try :
54- from langchain .chat_models import init_chat_model
5555 from langchain_core .messages import AnyMessage , HumanMessage
5656 from langgraph .graph import END , START , StateGraph
5757 from typing_extensions import TypedDict
@@ -72,7 +72,7 @@ def handle_traversal(node: AgentGraphNode, ctx: dict) -> None:
7272
7373 model = None
7474 if node_config .model :
75- lc_model = init_chat_model ( model = node_config . model . name )
75+ lc_model = create_langchain_model ( node_config )
7676 tool_defs = node_config .model .get_parameter ('tools' ) or []
7777 tool_fns = [
7878 tools_ref [t .get ('name' , '' )]
@@ -86,7 +86,7 @@ def handle_traversal(node: AgentGraphNode, ctx: dict) -> None:
8686 def invoke (state : WorkflowState ) -> WorkflowState :
8787 exec_path .append (node_key )
8888 if not model :
89- return state
89+ return { 'messages' : []}
9090 gk = tracker .graph_key if tracker is not None else None
9191 if node_tracker :
9292 response = node_tracker .track_metrics_of (
0 commit comments