mcp.servers.dataflow_server¶

Haive Dataflow MCP Server - Provides access to haive-dataflow registry and components.

Attributes¶

`DATAFLOW_AVAILABLE`
`logger`
`mcp`

Functions¶

`agent_creation_prompt`(→ str)	Generate a prompt for creating a new haive agent.
`component_search_prompt`(→ str)	Generate a prompt for searching haive components.
`create_agent_config`(→ dict[str, Any])	Create a configuration for a haive agent.
`discover_components`(→ dict[str, Any])	Run discovery for a specific component type.
`get_component_details`(→ dict[str, Any])	Get detailed information about a specific component.
`get_component_resource`(→ str)	Resource for specific component details.
`get_server_info`(→ dict[str, Any])	Get server information.
`list_all_components_resource`(→ str)	Resource listing all registered components.
`list_components`(→ dict[str, Any])	List components registered in haive-dataflow.
`register_component`(→ dict[str, str])	Register a new component in haive-dataflow.

Module Contents¶

async mcp.servers.dataflow_server.agent_creation_prompt(requirements: str) → str¶

Generate a prompt for creating a new haive agent.

Parameters:: requirements – Requirements for the agent
Returns:: Agent creation prompt

async mcp.servers.dataflow_server.component_search_prompt(query: str) → str¶

Generate a prompt for searching haive components.

Parameters:: query – Search query
Returns:: Search prompt

async mcp.servers.dataflow_server.create_agent_config(agent_type: str, name: str, model: str = 'gpt-4', temperature: float = 0.7) → dict[str, Any]¶

Create a configuration for a haive agent.

Parameters:

agent_type – Type of agent (simple, react, rag, multi)
name – Name for the agent
model – LLM model to use
temperature – Temperature setting

Returns:

Agent configuration

async mcp.servers.dataflow_server.discover_components(component_type: str) → dict[str, Any]¶

Run discovery for a specific component type.

Parameters:: component_type – Type to discover (agents, tools, engines, games)
Returns:: Discovery results

async mcp.servers.dataflow_server.get_component_details(component_id: str) → dict[str, Any]¶

Get detailed information about a specific component.

Parameters:: component_id – ID of the component
Returns:: Component details

async mcp.servers.dataflow_server.get_component_resource(component_id: str) → str¶: Resource for specific component details.

async mcp.servers.dataflow_server.get_server_info() → dict[str, Any]¶: Get server information.

async mcp.servers.dataflow_server.list_all_components_resource() → str¶: Resource listing all registered components.

async mcp.servers.dataflow_server.list_components(component_type: str = 'all') → dict[str, Any]¶

List components registered in haive-dataflow.

Parameters:: component_type – Type of components to list (agent, tool, engine, game, mcp_server, or all)
Returns:: Dictionary of components by type

async mcp.servers.dataflow_server.register_component(name: str, component_type: str, description: str, metadata: dict[str, Any] | None = None) → dict[str, str]¶

Parameters:

name – Component name
component_type – Type of component (agent, tool, engine, etc.)
description – Component description
metadata – Optional metadata dictionary

Returns:

Registration result with component ID

mcp.servers.dataflow_server.DATAFLOW_AVAILABLE = True¶

mcp.servers.dataflow_server.logger¶

mcp.servers.dataflow_server.mcp¶