+ iY$aR8t70tRt^RIt^RIt^RIt^RIt^RIHtHtH t H t H t ^RI H t ^RIHtHt]P"!]4tRs]P*!4t]P.!4tRtRtRtRt]!4^R IHt]!4^R I"H#t#]#!4] PH!4t%]^k] PL!4t']^k.s(]^kR RR.RR.RR.RR.RR.R.R9OR.R:ORR.R.R;OR.Rmt+RR0t,R$R%lt-R&R'lt.R?R(R)llt/R*R+lt0R@R,R-llt1R.R/lt2R0R1lt3R2R3lt4R4R5lt5R?R6R7llt6R# ]dt ]PCR ] 4Rt A LRt A ii;i ]dt ]PCR ] 4Rt A LRt A ii;i)Aa Model Tools Module Thin orchestration layer over the tool registry. Each tool file in tools/ self-registers its schema, handler, and metadata via tools.registry.register(). This module triggers discovery (by importing all tool modules), then provides the public API that run_agent.py, cli.py, batch_runner.py, and the RL environments consume. Public API (signatures preserved from the original 2,400-line version): get_tool_definitions(enabled_toolsets, disabled_toolsets, quiet_mode) -> list handle_function_call(function_name, function_args, task_id, user_task) -> str TOOL_TO_TOOLSET_MAP: dict (for batch_runner.py) TOOLSET_REQUIREMENTS: dict (for cli.py, doctor.py) get_all_tool_names() -> list get_toolset_for_tool(name) -> str get_available_toolsets() -> dict check_toolset_requirements() -> dict check_tool_availability(quiet) -> tuple N)DictAnyListOptionalTuple)registry)resolve_toolsetvalidate_toolsetc\;_uu_4\e\P4'd\P!4s\uuRRR4# +'giR#;i)aJReturn a long-lived event loop for running async tool handlers. Using a persistent loop (instead of asyncio.run() which creates and *closes* a fresh loop every time) prevents "Event loop is closed" errors that occur when cached httpx/AsyncOpenAI clients attempt to close their transport on a dead loop during garbage collection. N)_tool_loop_lock _tool_loop is_closedasyncionew_event_loop(/home/ubuntu/hermes-agent/model_tools.py_get_tool_loopr,s:   !5!5!7!7 //1J s"AA A( c\\RR4pVeVP4'd7\P!4p\P !V4V\nV#)uwReturn a persistent event loop for the current worker thread. Each worker thread (e.g., delegate_task's ThreadPoolExecutor threads) gets its own long-lived loop stored in thread-local storage. This prevents the "Event loop is closed" errors that occurred when asyncio.run() was used per-call: asyncio.run() creates a loop, runs the coroutine, then *closes* the loop — but cached httpx/AsyncOpenAI clients remain bound to that now-dead loop and raise RuntimeError during garbage collection or subsequent use. By keeping the loop alive for the thread's lifetime, cached clients stay valid and their cleanup runs on a live loop. loopN)getattr_worker_thread_localr rrset_event_loopr)rs r_get_worker_loopr;sN ' 6D |t~~''%%'t$$(! KrcD\P!4pV'd|VP4'df^RIpVP P ^R7;_uu_4pVP\PV4pVPRR7uuRRR4#\P!4\P!4Jd\4pVPV4#\4pVPV4# \dRpLi;i +'giL;i)aRun an async coroutine from a sync context. If the current thread already has a running event loop (e.g., inside the gateway's async stack or Atropos's event loop), we spin up a disposable thread so asyncio.run() can create its own loop without conflicting. For the common CLI path (no running loop), we use a persistent event loop so that cached async clients (httpx / AsyncOpenAI) remain bound to a live loop and don't trigger "Event loop is closed" on GC. When called from a worker thread (parallel tool execution), we use a per-thread persistent loop to avoid both contention with the main thread's shared loop AND the "Event loop is closed" errors caused by asyncio.run()'s create-and-destroy lifecycle. This is the single source of truth for sync->async bridging in tool handlers. The RL paths (agent_loop.py, tool_context.py) also provide outer thread-pool wrapping as defense-in-depth, but each handler is self-protecting via this function. N) max_workersi,)timeout)rget_running_loop RuntimeError is_runningconcurrent.futuresfuturesThreadPoolExecutorsubmitrunresult threadingcurrent_thread main_threadrrun_until_completer)coror concurrentpoolfuture worker_loop tool_loops& r _run_asyncr0Qs,'') !!!    2 2q 2 A AT[[d3F===-B A!)>)>)@@&( --d33 I  ' ' --)  B AsC<2D< D  D  D c.ROp^RIpVFpVPV4K R# \d"p\P RY#4Rp?KBRp?ii;i)zImport all tool modules to trigger their registry.register() calls. Wrapped in a function so import errors in optional tools (e.g., fal_client not installed) don't prevent the rest from loading. Nz#Could not import tool module %s: %s)ztools.web_toolsztools.terminal_toolztools.file_toolsztools.vision_toolsztools.mixture_of_agents_toolztools.image_generation_toolztools.skills_toolztools.skill_manager_toolztools.browser_toolztools.cronjob_toolsztools.rl_training_toolztools.tts_toolztools.todo_toolztools.memory_toolztools.session_search_toolztools.clarify_toolztools.code_execution_toolztools.delegate_toolztools.process_registryztools.send_message_toolztools.homeassistant_tool) importlib import_module Exceptionloggerwarning)_modulesr2mod_namees r_discover_toolsr:sR H0 O  # #H - O NN@( N N Os& AA  A)discover_mcp_toolszMCP tool discovery failed: %s)discover_pluginszPlugin discovery failed: %s web_tools web_search web_extractterminal_toolsterminal vision_toolsvision_analyze moa_toolsmixture_of_agents image_toolsimage_generate skills_tools browser_tools cronjob_toolscronjobrl_tools file_tools read_file search_files tts_toolstext_to_speechc V^8dQhR\\,R\\,R\R\\\\3,,/#)enabled_toolsetsdisabled_toolsets quiet_modereturn)rstrboolrr)formats"r __annotate__r[sKww3iwCyww $sCx. wrc \4pVeVFp\V4'dS\V4pVPV4V'g-\ RT RV'dRP V4MR 24KdKfV\ 9dK\ V,pVPV4V'g#\ RV RRP V4 24KKV'dK\ RV 24K EM?V'Ed ^RIHpV!4FpVP\V44K VFp\V4'dS\V4pVPV4V'g-\ RT RV'dRP V4MR 24KdKfV\ 9dK\ V,pVPV4V'g#\ R V RRP V4 24KKV'dK\ RV 24K M.^RIHpV!4FpVP\V44K \P!W2R 7p V U u0uFqR ,R ,kK p p R V 9d_^RI H p Hp W,pV !V4p\V 4F7wppVP!R /4P!R 4R 8XgK.RR R V/V V&M RV 9dRR0V ,pV'g\V 4FowppVP!R /4P!R 4R8XgK.VR ,P!RR4pVP#RR4pRR R /VR ,CRV/C/V V&M V'g\V 'dIV U u.uFqR ,R ,NK pp \ R\%V 4 RRP V4 24M \ R4V U u.uFqR ,R ,NK up sV #uup iuup iuup i)a Get tool definitions for model API calls with toolset-based filtering. All tools must be part of a toolset to be accessible. Args: enabled_toolsets: Only include tools from these toolsets. disabled_toolsets: Exclude tools from these toolsets (if enabled_toolsets is None). quiet_mode: Suppress status prints. Returns: Filtered list of OpenAI-format tool definitions. u✅ Enabled toolset 'z': z, zno toolsu✅ Enabled legacy toolset 'u⚠️ Unknown toolset: )get_all_toolsetsu🚫 Disabled toolset 'u🚫 Disabled legacy toolset 'quietfunctionname execute_code)SANDBOX_ALLOWED_TOOLSbuild_execute_code_schematypebrowser_navigater>r? descriptionzV For simple information retrieval, prefer web_search or web_extract (faster, cheaper).u🛠️ Final tool selection (z tools): u<🛠️ No tools selected (all filtered out or unavailable))setr rupdateprintjoin_LEGACY_TOOLSET_MAPtoolsetsr]difference_updaterget_definitionstools.code_execution_toolrcrd enumerategetreplacelen_last_resolved_tool_names)rTrUrVtools_to_include toolset_nameresolved legacy_toolsr]ts_namefiltered_toolstavailable_tool_namesrcrdsandbox_enableddynamic_schemaitdweb_tools_availabledesc tool_namess&&& rget_tool_definitionsrs& E#,L --*<8 ''1!1,sZb499XCVhrBstu"!442<@  '' 5!8c$))T`JaIbcd""z5l^DE-  -')G  # #OG$< =*.L --*<8 228<!3L>\dTYYxEXjtDuvw"!442<@  22<@!:<.DIIVbLcKdef""z5l^DE. .')G  # #OG$< =*--.>QN ajM&11>J --^/F2?C~.EArvvj"%))&1^C%+Z^$Tq!/11+];>RR"">2266*b)--f59KKj>--mR@D<<pD  "$Kr*~$K}d$K)N1%3  9GHAJ-//JH 3C4G3H RVR[R[\fRgQhi j P QAO O1:v!6!6 O [KJI !PsO/O$O)cV^8dQhR\R\\\3,R\\\3,/#)rS tool_nameargsrW)rXrr)rZs"rr[r[ts1$$$4S>$d38n$rcV'd\V\4'gV#\P!V4pV'gV#VP R4;'g/P R4pV'gV#VP 4FiwrE\V\ 4'gKVP V4pV'gK8VP R4pV'gKS\WW4pWJgKeWV&Kk V#)a!Coerce tool call arguments to match their JSON Schema types. LLMs frequently return numbers as strings (``"42"`` instead of ``42``) and booleans as strings (``"true"`` instead of ``true``). This compares each argument value against the tool's registered JSON Schema and attempts safe coercion when the value is a string but the schema expects a different type. Original values are preserved when coercion fails. Handles ``"type": "integer"``, ``"type": "number"``, ``"type": "boolean"``, and union types (``"type": ["integer", "string"]``). parameters propertiesre) isinstancedictr get_schemarsitemsrX _coerce_value) rrschemarkeyvalue prop_schemaexpectedcoerceds && rcoerce_tool_argsrts z$--   +F  **\*00b55lCJ  jjl %%%  nnS)  ??6* 0  I# Krc$V^8dQhR\/#rSrrX)rZs"rr[r[src\V\4'd VFp\W4pW0JgKVu# V#VR9d\WR8HR7#VR8Xd \ V4#V#)z~Attempt to coerce a string *value* to *expected_type*. Returns the original string when coercion is not applicable or fails. integer) integer_onlyboolean)rnumber)rlistr_coerce_number_coerce_boolean)r expected_typer}r%s&& rrrsh -&&A"5,F"  --eI3MOO !u%% Lrc0V^8dQhR\R\/#)rSrr)rXrY)rZs"rr[r[s  # T rc\V4pY"8wg!T\R48XgT\R48XdT#T\T48Xd \T4#T'dT#T# \\3dTu#i;i)zFTry to parse *value* as a number. Returns original string on failure.infz-inf)float ValueError OverflowErrorint)rrfs&& rrrsn %L veEl"a5=&8CF{1v  H  & s AA21A2c$V^8dQhR\/#rr)rZs"rr[r[s3rcfVP4P4pVR8XdR#VR8XdR#V#)zGTry to parse *value* as a boolean. Returns original string on failure.trueTfalseF)striplower)rlows& rrrs/ ++-   C f} g~ LrcV^8dQhR\R\\\3,R\\,R\\,R\\,R\\,R\\\,,R\/#) rS function_name function_argstask_id tool_call_id session_id user_task enabled_toolsrW)rXrrrr)rZs"rr[r[sYDYDYDS>YDc]YD3- YD  YD } YDDI&YD YDrc $\W4pV\9d^RIHpT!T;'gR4V\ 9d\ P!RV R2/4#^RIH pT!RTTT;'gRT;'gRT;'gRR7VR 8Xd'VeTM\p \P!WVV R 7p M\P!WVVR 7p ^RIH pT!R TTT T;'gRT;'gRT;'gRR7V # \dLi;i \dLi;i \dT #i;i \dKp RT R\T 4 2p \PT 4\ P!RT /RR7uR p ? #R p ? ii;i)a Main function call dispatcher that routes calls to the tool registry. Args: function_name: Name of the function to call. function_args: Arguments for the function. task_id: Unique identifier for terminal/browser session isolation. user_task: The user's original task (for browser_snapshot context). enabled_tools: Tool names enabled for this session. When provided, execute_code uses this list to determine which sandbox tools to generate. Falls back to the process-global ``_last_resolved_tool_names`` for backward compat. Returns: Function result as a JSON string. )notify_other_tool_calldefaulterrorz" must be handled by the agent loop) invoke_hook pre_tool_callrh)rrrrrrbN)rr)rrpost_tool_call)rrr%rrrzError executing z: F) ensure_ascii)r_READ_SEARCH_TOOLStools.file_toolsrr4_AGENT_LOOP_TOOLSjsondumpshermes_cli.pluginsrrvrdispatchrXr5r) rrrrrrrrrrr%r9 error_msgs &&&&&&& rhandle_function_callrs4%]BM..  ? "7#7#7i 84D - -::w=/9[(\]^ ^  6 '" 2%++)//R   N *0=/HmNgO&&-F &&#F  6  '" 2%++)//R  e   "   <     D&}oRAx@  Yzz7I.UCCDsDD%D:D, D7 DD AD:D(& D(1 D(<D(D: DD D%"D:$D%%D:( D73D:6D77D:: F?F F Fc:V^8dQhR\\,/#rSrW)rrX)rZs"rr[r[+s))DI)rc,\P!4#)z!Return all registered tool names.)rget_all_tool_namesrrrrr+s  & & ((rcFV^8dQhR\R\\,/#)rSrrW)rXr)rZs"rr[r[0s44C4HSM4rc.\P!V4#)z%Return the toolset a tool belongs to.)rget_toolset_for_tool)rs&rrr0s  ( ( 33rcFV^8dQhR\\\3,/#r)rrXr)rZs"rr[r[5s--S$Y-rc,\P!4#)z0Return toolset availability info for UI display.)rget_available_toolsetsrrrrr5s  * * ,,rcFV^8dQhR\\\3,/#r)rrXrY)rZs"rr[r[:s11DdO1rc,\P!4#)z>Return {toolset: available_bool} for every registered toolset.)rcheck_toolset_requirementsrrrrr:s  . . 00rc~V^8dQhR\R\\\,\\,3,/#)rSr_rW)rYrrrXr)rZs"rr[r[?s,9949E$s)T$Z:O4P9rc0\P!VR7#)z.Return (available_toolsets, unavailable_info).r^)rcheck_tool_availabilityr^s&rrr?s  + +% 88rcV^8dQh/^\9d\\\3,;R&^\9d\\\3,;R&^\9d\\,;R&#)rSTOOL_TO_TOOLSET_MAPTOOLSET_REQUIREMENTSrv)__conditional_annotations__rrXrr)rZs"rr[r[s^zIHT#s(^H{~LKd39oKF*)49)Gr) skills_list skill_view skill_manage) rfbrowser_snapshot browser_click browser_typebrowser_scroll browser_back browser_press browser_closebrowser_get_imagesbrowser_visionbrowser_console) rl_list_environmentsrl_select_environmentrl_get_current_configrl_edit_configrl_start_trainingrl_check_statusrl_stop_trainingrl_get_results rl_list_runsrl_test_inference)rN write_filepatchrO)NNF>todomemory delegate_tasksession_search)F)NNNNN)8r__doc__rrloggingr&typingrrrrrtools.registryrrnrr getLogger__name__r5r Lockr localrrrr0r:tools.mcp_toolr;r4r9debugrr<get_tool_to_toolset_maprget_toolset_requirementsrrvrmrrrrrrrrrrrrrr[)rs@rr s* 33#6   8 $ .." ( ,,.f#OL51 33'/&F&F&HH(0(I(I(KK(*), .zl%&%&$%A i[F"#-2$N( $YD@) 4 - 1 99_ 5 LL0!4453 LL.223s0? E E,E) E$$E),F3F  F