Flowfile

Main Repository: Edwardvaneechoud/Flowfile
Documentation: Website - Core - Worker - Frontend - Technical Architecture

Flowfile is an open-source data platform that combines a visual pipeline builder, a data catalog with Delta Lake storage, scheduling, Kafka ingestion, sandboxed Python execution, and a Polars-compatible Python API — all in a single pip install.

Quick Start

pip install Flowfile
flowfile run ui

This starts the backend services and opens the visual ETL interface in your browser.

What You Get

Visual pipeline builder with 30+ nodes for joins, filters, aggregations, fuzzy matching, pivots, and more
Data catalog with Delta Lake storage, version history, and lineage tracking
Scheduling — interval-based or triggered by catalog table updates
Kafka/Redpanda ingestion as a canvas node with automatic schema inference
Sandboxed Python execution in isolated Docker containers
Code generation — export visual flows as standalone Python/Polars scripts
Flow parameters — ${variable} substitution, configurable via UI or CLI
Cloud storage — S3, Azure Data Lake Storage, Google Cloud Storage
Database connectivity — PostgreSQL, MySQL, SQL Server, Oracle, DuckDB, and more
Python API with Polars-like syntax and visual flow graph generation

Python API

import flowfile as ff
from flowfile import col, open_graph_in_editor

df = ff.from_dict({
    "id": [1, 2, 3, 4, 5],
    "category": ["A", "B", "A", "C", "B"],
    "value": [100, 200, 150, 300, 250]
})

result = df.filter(col("value") > 150).with_columns([
    (col("value") * 2).alias("double_value")
])

# Open the pipeline on the visual canvas
open_graph_in_editor(result.flow_graph)

Common Operations

import flowfile as ff
from flowfile import col, when, lit

# Read from various sources
df = ff.read_csv("data.csv")
df_pq = ff.read_parquet("data.parquet")

# Transform
filtered = df.filter(col("value") > 150)
with_status = df.with_columns([
    when(col("value") > 200).then(lit("High")).otherwise(lit("Low")).alias("status")
])

# Aggregate
by_category = df.group_by("category").agg([
    col("value").sum().alias("total"),
    col("value").mean().alias("average")
])

# Join
joined = df.join(other_df, left_on="id", right_on="product_id")

# Visualize any pipeline
ff.open_graph_in_editor(joined.flow_graph)

Code Generation

Export visual flows as standalone Python/Polars scripts:

Code Generation

Package Components

Core Service (flowfile_core) — ETL engine, catalog, scheduler, auth
Worker Service (flowfile_worker) — CPU-intensive data processing
Web UI — Browser-based visual pipeline builder
FlowFrame API (flowfile_frame) — Polars-compatible Python library
Scheduler (flowfile_scheduler) — Interval and table-trigger scheduling

CLI

flowfile run ui                              # Start web UI
flowfile run core --host 0.0.0.0             # Start core service
flowfile run worker --host 0.0.0.0           # Start worker service
flowfile run flow pipeline.json              # Run a flow
flowfile run flow pipeline.json --param key=value  # Run with parameters

More Options

Desktop App: Download from GitHub Releases
Docker: docker compose up -d for self-hosted deployments
Browser Demo: demo.flowfile.org (WASM, no server)

Resources

Documentation: Comprehensive guides
Main Repository: Latest code and examples
Technical Architecture: Design overview

Release files for Flowfile 0.17.6

For a detailed explanation of source distributions (sdists) and built distributions (wheels), please see the package formats documentation.

Source distribution (sdist)

Source distribution for Flowfile 0.17.6
File	Size	Uploaded
flowfile-0.17.6.tar.gz	9.3 MB	Sep 15, 2026	Details

Built distribution (wheel)

Table of built distributions (wheels) for Flowfile 0.17.6
File	Interpreter	ABI	Platform	Reset
flowfile-0.17.6-py3-none-any.whl 9.9 MB Sep 15, 2026	Python 3	none	any	Details

Total release size: 19.3 MB

Release files / flowfile-0.17.6.tar.gz

Download URL	flowfile-0.17.6.tar.gz
Size	9.3 MB
Tags	Source
SHA-256 checksum How to use checksums	`38b8b82198bba8035643bf8bead145e6df6d905fb67cc3a327820f86e2e825e7`
BLAKE2b-256 checksum How to use checksums	`605ffc51997e821a53092dac7c74620a5fdf8c98f1b81faf0b43cdadcc4a4f8a`
Upload date	Sep 15, 2026
Uploaded using Trusted Publishing? What is trusted publishing?	Yes
Uploaded via	`twine/7.0.0 CPython/3.13.14`

Provenance

Provenance describes where a file came from. On PyPI, provenance is shared via attestations, which provide a verifiable record of the build or publishing details. View details, limitations and caveats.

Identity

Publishing platform: GitHub Actions
Publishing repository: github.com/Edwardvaneechoud/Flowfile
Publishing commit: github.com/Edwardvaneechoud/Flowfile/tree/d4edda94d249c2464b93b23db4bebbdb8cf5063b

Workflow

Publishing configuration: github.com/Edwardvaneechoud/Flowfile/blob/d4edda94d249c2464b93b23db4bebbdb8cf5063b/.github/workflows/pypi-release.yml
Publishing logs: github.com/Edwardvaneechoud/Flowfile/actions/runs/35001176297/attempts/1

Artifact

Subject: flowfile-0.17.6.tar.gz
SHA-256 checksum: 38b8b82198bba8035643bf8bead145e6df6d905fb67cc3a327820f86e2e825e7 Verifying attestations

Release files / flowfile-0.17.6-py3-none-any.whl

Download URL	flowfile-0.17.6-py3-none-any.whl
Size	9.9 MB
Tags	Python 3
SHA-256 checksum How to use checksums	`2be7a0c349ed0559784e0e0e19026d8e41997f115a61eb1fe83df12a231c9804`
BLAKE2b-256 checksum How to use checksums	`806d0ba6cb2a34b93f8b80313ea0ece1e5a27f7ace3822a960954816485d1d80`
Upload date	Sep 15, 2026
Uploaded using Trusted Publishing? What is trusted publishing?	Yes
Uploaded via	`twine/7.0.0 CPython/3.13.14`

Provenance

Identity

Publishing platform: GitHub Actions
Publishing repository: github.com/Edwardvaneechoud/Flowfile
Publishing commit: github.com/Edwardvaneechoud/Flowfile/tree/d4edda94d249c2464b93b23db4bebbdb8cf5063b

Workflow

Publishing configuration: github.com/Edwardvaneechoud/Flowfile/blob/d4edda94d249c2464b93b23db4bebbdb8cf5063b/.github/workflows/pypi-release.yml
Publishing logs: github.com/Edwardvaneechoud/Flowfile/actions/runs/35001176297/attempts/1

Artifact

Subject: flowfile-0.17.6-py3-none-any.whl
SHA-256 checksum: 2be7a0c349ed0559784e0e0e19026d8e41997f115a61eb1fe83df12a231c9804 Verifying attestations