hap.types.nodes

HAP type definitions for Haive graph nodes.

This module defines HAP protocol types for exposing various node types used in Haive graphs.

Classes

AgentNodeInfo	Information about agent nodes.
CallableNodeInfo	Information about callable/function nodes.
MultiAgentNodeInfo	Information about multi-agent nodes.
NodeConfigInfo	Base information about a node configuration.
NodeCreationRequest	Request to create a new node.
NodeExecutionRequest	Request to execute a specific node.
NodeExecutionResult	Result from node execution.
NodeIntrospectionResult	Result of node introspection.
NodeUpdateRequest	Request to update a node configuration.
ParserNodeInfo	Information about parser nodes.
ToolNodeInfo	Information about tool nodes.
ToolNodeResult	Result from tool node execution.
ValidationNodeInfo	Information about validation nodes.
ValidationNodeResult	Result from validation node execution.

Module Contents

class hap.types.nodes.AgentNodeInfo(/, **data: Any)

Bases: NodeConfigInfo

Information about agent nodes.

Parameters:

data (Any)

agent_class: str = None

agent_name: str = None

has_post_agent: bool = None

has_pre_agent: bool = None

node_type: Literal['agent'] = 'agent'

supports_async: bool = None

class hap.types.nodes.CallableNodeInfo(/, **data: Any)

Bases: NodeConfigInfo

Information about callable/function nodes.

Parameters:

data (Any)

function_name: str = None

function_signature: str = None

is_async: bool = None

node_type: Literal['callable'] = 'callable'

class hap.types.nodes.MultiAgentNodeInfo(/, **data: Any)

Bases: NodeConfigInfo

Information about multi-agent nodes.

Parameters:

data (Any)

agents: list[str] = None

execution_mode: Literal['sequential', 'parallel', 'conditional'] = None

node_type: Literal['multi_agent'] = 'multi_agent'

routing_config: dict[str, Any] | None = None

class hap.types.nodes.NodeConfigInfo(/, **data: Any)

Bases: haive.hap.types.BaseInfo

Base information about a node configuration.

Parameters:

data (Any)

configuration: dict[str, Any] = None

input_fields: list[str] = None

node_class: str = None

node_type: str = None

output_fields: list[str] = None

requires_state_schema: bool = None

supports_streaming: bool = None

class hap.types.nodes.NodeCreationRequest(/, **data: Any)

Bases: pydantic.BaseModel

Request to create a new node.

Parameters:

data (Any)

config: dict[str, Any] = None

input_mapping: dict[str, str] | None = None

name: str = None

node_type: str = None

output_mapping: dict[str, str] | None = None

class hap.types.nodes.NodeExecutionRequest(/, **data: Any)

Bases: pydantic.BaseModel

Request to execute a specific node.

Parameters:

data (Any)

config: dict[str, Any] | None = None

node_name: str = None

state: dict[str, Any] = None

class hap.types.nodes.NodeExecutionResult(/, **data: Any)

Bases: pydantic.BaseModel

Result from node execution.

Parameters:

data (Any)

duration_ms: float | None = None

error: str | None = None

metadata: dict[str, Any] = None

output: dict[str, Any] | None = None

status: Literal['success', 'error', 'skipped'] = None

class hap.types.nodes.NodeIntrospectionResult(/, **data: Any)

Bases: pydantic.BaseModel

Result of node introspection.

Parameters:

data (Any)

can_execute: bool = None

dependencies: list[str] = None

missing_requirements: list[str] = None

node_info: NodeConfigInfo = None

node_name: str = None

performance_stats: dict[str, Any] | None = None

class hap.types.nodes.NodeUpdateRequest(/, **data: Any)

Bases: pydantic.BaseModel

Request to update a node configuration.

Parameters:

data (Any)

node_name: str = None

update_mappings: bool = None

updates: dict[str, Any] = None

class hap.types.nodes.ParserNodeInfo(/, **data: Any)

Bases: NodeConfigInfo

Information about parser nodes.

Parameters:

data (Any)

node_type: Literal['parser'] = 'parser'

output_model: str | None = None

parser_type: str = None

supports_streaming: bool = None

class hap.types.nodes.ToolNodeInfo(/, **data: Any)

Bases: NodeConfigInfo

Information about tool nodes.

Parameters:

data (Any)

node_type: Literal['tool'] = 'tool'

parallel_execution: bool = None

tool_names: list[str] = None

tool_schemas: dict[str, dict[str, Any]] = None

class hap.types.nodes.ToolNodeResult(/, **data: Any)

Bases: NodeExecutionResult

Result from tool node execution.

Parameters:

data (Any)

parallel_execution: bool = None

tool_calls: list[dict[str, Any]] = None

tool_results: dict[str, Any] = None

class hap.types.nodes.ValidationNodeInfo(/, **data: Any)

Bases: NodeConfigInfo

Information about validation nodes.

Parameters:

data (Any)

max_retries: int = None

node_type: Literal['validation'] = 'validation'

supports_retry: bool = None

tool_routes: dict[str, str] = None

validation_model: str | None = None

class hap.types.nodes.ValidationNodeResult(/, **data: Any)

Bases: NodeExecutionResult

Result from validation node execution.

Parameters:

data (Any)

final_output: Any | None = None

retry_count: int = None

validation_errors: list[dict[str, Any]] = None

validation_passed: bool = None