API

Public Modules

flowno

Flowno: A Python DSL for building dataflow programs.

flowno.io

Internal Modules

flowno.core.flow_hdl

FlowHDL: Hardware Description Language-inspired context for defining dataflow graphs.

flowno.core.flow.flow

Flow execution and graph resolution module for Flowno.

flowno.core.flow.instrumentation

Instrumentation system for Flowno's dataflow execution.

flowno.core.mono_node

Type definitions for mono nodes in Flowno's typechecking system.

flowno.core.streaming_node

Type definitions for streaming nodes in Flowno's typechecking system.

flowno.core.node_base

Core node types and base classes for the Flowno dataflow system.

flowno.core.event_loop.event_loop

Custom event loop implementation for Flowno's asynchronous execution model.

flowno.core.event_loop.commands

Internal Command Types for the Flowno Event Loop

flowno.core.event_loop.instrumentation

Event Loop Instrumentation System.

flowno.core.event_loop.primitives

Low-level concurrency primitives for the Flowno event loop.

flowno.core.event_loop.queues

Asynchronous queue implementations for the Flowno event loop.

flowno.core.event_loop.types

Type definitions for Flowno's event loop system.

flowno.core.event_loop.selectors

Socket abstraction for the Flowno event loop.

flowno.core.event_loop.tasks

Task management for the Flowno event loop.

flowno.core.event_loop.synchronization

Synchronization primitives for the Flowno event loop.

flowno.utilities.logging

Logging utilities for asynchronous code in Flowno.

flowno.utilities.coroutine_wrapper

Coroutine wrapper for Flowno's asynchronous execution logging.

flowno.utilities.asyncgen_wrapper

Async generator wrapper for Flowno's asynchronous execution logging.

flowno.io.http_client

HTTP Client for Flowno applications.

flowno.io.http_server

Simple HTTP server implementation for Flowno applications.

flowno.decorators.node()

Decorator that transforms async functions or classes into DraftNode subclasses.

flowno.decorators.single_output

Single output node creation utilities for Flowno.

flowno.decorators.multiple_output

Multiple output node creation utilities for Flowno.

flowno.decorators.node_meta_single_dec

Node meta decoration for single-output Flowno nodes.

flowno.decorators.node_meta_multiple_dec

Node meta decoration for multiple-output Flowno nodes.

flowno.utilities.helpers

Generation tracking utilities for Flowno's dataflow execution system.

flowno.io.headers

HTTP header handling for Flowno's HTTP client.