File tree Expand file tree Collapse file tree 1 file changed +9
-0
lines changed
src/uipath_langchain/_cli/_runtime Expand file tree Collapse file tree 1 file changed +9
-0
lines changed Original file line number Diff line number Diff line change 11import json
22import logging
3+ import os
34from typing import List , Optional
45
56from langchain_core .callbacks .base import BaseCallbackHandler
@@ -88,6 +89,14 @@ async def execute(self) -> Optional[UiPathRuntimeResult]:
8889 "callbacks" : callbacks ,
8990 }
9091
92+ recursion_limit = os .environ .get ("LANGCHAIN_RECURSION_LIMIT" , None )
93+ max_concurrency = os .environ .get ("LANGCHAIN_MAX_CONCURRENCY" , None )
94+
95+ if recursion_limit is not None :
96+ graph_config ["recursion_limit" ] = int (recursion_limit )
97+ if max_concurrency is not None :
98+ graph_config ["max_concurrency" ] = int (max_concurrency )
99+
91100 # Stream the output at debug time
92101 if self .context .job_id is None :
93102 # Get final chunk while streaming
You can’t perform that action at this time.
0 commit comments