mirror of
https://github.com/NousResearch/hermes-agent.git
synced 2026-05-18 04:41:56 +00:00
4816646109
Migrates Parallel.ai from inline `_parallel_search()` / `_parallel_extract()`
in tools/web_tools.py to a bundled plugin at plugins/web/parallel/.
First plugin in the codebase to expose an async :meth:`extract`:
- search() is sync — Parallel.beta.search
- extract() is **async def** — AsyncParallel.beta.extract
The ABC's docstring on supports_extract() already permits sync-or-async;
this commit is the first to exercise the async path. The web_extract_tool
dispatcher (next commit) detects coroutines via
inspect.iscoroutinefunction and awaits accordingly.
Behavior preserved:
- PARALLEL_API_KEY required (raises ValueError if missing → surfaced
as {"success": False, "error": "..."} instead)
- PARALLEL_SEARCH_MODE env var honored (agentic|fast|one-shot, default
agentic), validated via _resolve_search_mode()
- Limit capped at 20 server-side via min(limit, 20)
- Per-URL failure mode preserved: response.errors[] each become a
result dict with an "error" field rather than raising
- Module-level _parallel_client / _async_parallel_client caches kept
(mirrors legacy singleton pattern)
Adds "parallel" to _WEB_PLUGIN_SKIPLIST in hermes_cli/tools_config.py so
the picker doesn't double-list.
The legacy inline _parallel_search, _parallel_extract, _get_parallel_client,
_get_async_parallel_client in tools/web_tools.py are NOT deleted yet — the
dispatcher still calls them. They go away when the dispatcher cuts over.
E2E verified:
- inspect.iscoroutinefunction(p.search) -> False
- inspect.iscoroutinefunction(p.extract) -> True
- extract() returns a coroutine (not a list)
- 5 providers register correctly (brave-free, ddgs, exa, parallel, searxng)
16 lines
573 B
Python
16 lines
573 B
Python
"""Parallel.ai web search + extract plugin — bundled, auto-loaded.
|
|
|
|
First plugin in this repo to expose an async :meth:`extract` — Parallel's
|
|
SDK is async-native (``AsyncParallel.beta.extract``). The web_extract_tool
|
|
dispatcher detects coroutines via :func:`inspect.iscoroutinefunction` and
|
|
awaits.
|
|
"""
|
|
|
|
from __future__ import annotations
|
|
|
|
from plugins.web.parallel.provider import ParallelWebSearchProvider
|
|
|
|
|
|
def register(ctx) -> None:
|
|
"""Register the Parallel provider with the plugin context."""
|
|
ctx.register_web_search_provider(ParallelWebSearchProvider())
|