dataflow.registry.db

Database schema and operations for the registry system.

This module provides database integration for the registry system, focusing on: 1. Schema creation and migration 2. Supabase integration 3. Relations between registry items and state schemas 4. Agent graph storage

Attributes

registry_db

Classes

AgentGraph	Graph representation of an agent's components.
RegistrySchema	Schema for a registry item in Supabase.
SchemaDefinition	Schema definition for a component, such as input/output/state schema.

Module Contents

class dataflow.registry.db.AgentGraph(/, **data: Any)

Bases: pydantic.BaseModel

Graph representation of an agent’s components.

agent_id: str

edges: list[dict[str, Any]]

id: str | None = None

nodes: list[dict[str, Any]]

timestamp: datetime.datetime = None

class dataflow.registry.db.RegistrySchema(/, **data: Any)

Bases: pydantic.BaseModel

Schema for a registry item in Supabase.

class Config

arbitrary_types_allowed = True

class_name: str

description: str = ''

id: str | None = None

item_type: str

metadata: dict[str, Any] = None

module_path: str

name: str

timestamp: datetime.datetime = None

class dataflow.registry.db.SchemaDefinition(/, **data: Any)

Bases: pydantic.BaseModel

Schema definition for a component, such as input/output/state schema.

id: str | None = None

registry_item_id: str

schema_json: dict[str, Any]

schema_type: str

timestamp: datetime.datetime = None

dataflow.registry.db.registry_db