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

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)

Bases: pydantic.BaseModel

Graph representation of an agent’s components.

Create a new model by parsing and validating input data from keyword arguments.

Raises [ValidationError][pydantic_core.ValidationError] if the input data cannot be validated to form a valid model.

self is explicitly positional-only to allow self as a field name.

Parameters:

data (Any)

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

Bases: pydantic.BaseModel

Schema for a registry item in Supabase.

Create a new model by parsing and validating input data from keyword arguments.

Raises [ValidationError][pydantic_core.ValidationError] if the input data cannot be validated to form a valid model.

self is explicitly positional-only to allow self as a field name.

Parameters:

data (Any)

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

Bases: pydantic.BaseModel

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

Create a new model by parsing and validating input data from keyword arguments.

Raises [ValidationError][pydantic_core.ValidationError] if the input data cannot be validated to form a valid model.

self is explicitly positional-only to allow self as a field name.

Parameters:

data (Any)