API Documentation

DaggerML - A Python library for building and managing directed acyclic graphs.

This library provides tools for creating, manipulating, and executing DAGs with strong typing support and a context-manager based interface.

class daggerml.Dag(dml, token, dump=None, message_handler=None)

Bases: object

Representation of a DaggerML DAG.

Parameters:

• dml (Dml) – DaggerML instance

• token (str) – DAG token

• dump (str, optional) – Serialized DAG data

• message_handler (callable, optional) – Function to handle messages

commit(value)

Commit a value to the DAG.

Parameters:

value (Union[Node, Error, Any]) – Value to commit

Return type:

NewType(Node, None)

dml: Dml

dump: str | None = None

property expr: Node

Access the dag’s expr node

load(dag_name, *, name=None, doc=None)

Load a DAG by name.

Parameters:

• dag_name (str) – Name of the DAG to load

• name (str, optional) – Name for the node

• doc (str, optional) – Documentation

Returns:

Node representing the loaded DAG

Return type:

Node

message_handler: Optional[Callable] = None

put(value, *, name=None, doc=None)

Add a value to the DAG.

Parameters:

• value (Union[Scalar, Collection]) – Value to add

• name (str, optional) – Name for the node

• doc (str, optional) – Documentation

Returns:

Node representing the value

Return type:

Node

token: str

class daggerml.Dml(*, data=None, message_handler=None, **kwargs)

Bases: object

Main DaggerML interface for creating and managing DAGs.

Parameters:

• data (Any, optional) – Initial data for the DML instance

• message_handler (callable, optional) – Function to handle messages

• **kwargs (dict) – Additional configuration options

Examples

>>> from daggerml import Dml
>>> with Dml() as dml:
...     with dml.new("d0", "message") as dag:
...         pass

new(name, message)

Create a new DAG.

Parameters:

• name (str) – Name of the DAG

• message (str) – Description or commit message

Returns:

New Dag instance

Return type:

Dag

Examples

>>> with dml.new("dag name", "message") as dag:
...     pass

exception daggerml.Error(message, context=<factory>, code=None)

Bases: Exception

Custom error type for DaggerML.

Parameters:

• message (Union[str, Exception]) – Error message or exception

• context (dict, optional) – Additional error context

• code (str, optional) – Error code

Return type:

None

code: str | None = None

context: dict

message: str | Exception

class daggerml.Node(dag, ref)

Bases: object

Representation of a node in a DaggerML DAG.

Parameters:

• dag (Dag) – Parent DAG

• ref (Ref) – Node reference

dag: Dag

items()

Iterate over key-value pairs of a dictionary node.

Returns:

Iterator over (key, value) pairs

Return type:

Iterator[tuple[Node, Node]]

keys(*, name=None, doc=None)

Get the keys of a dictionary node.

Parameters:

• name (str, optional) – Name for the result node

• doc (str, optional) – Documentation

Returns:

Node containing the dictionary keys

Return type:

Node

len(*, name=None, doc=None)

Get the length of a collection node.

Parameters:

• name (str, optional) – Name for the result node

• doc (str, optional) – Documentation

Returns:

Node containing the length

Return type:

Node

ref: Ref

type(*, name=None, doc=None)

Get the type of this node.

Parameters:

• name (str, optional) – Name for the result node

• doc (str, optional) – Documentation

Returns:

Node containing the type information

Return type:

Node

value()

Get the concrete value of this node.

Returns:

The actual value represented by this node

Return type:

Any

class daggerml.Ref(to)

Bases: object

Reference to a DaggerML node.

Parameters:

to (str) – Reference identifier

to: str

class daggerml.Resource(uri, data=None, adapter=None)

Bases: object

Representation of an external resource.

Parameters:

• uri (str) – Resource URI

• data (str, optional) – Associated data

• adapter (str, optional) – Resource adapter name

adapter: str | None

data: str | None

uri: str

daggerml.from_json(text)

Parse JSON string into Python objects.

Parameters:

text (str) – JSON string to parse

Returns:

Deserialized Python object

Return type:

Any

daggerml.to_json(obj)

Convert Python object to JSON string.

Parameters:

obj (Any) – Object to serialize

Returns:

JSON string representation

Return type:

str