flupy

library1.2.4pypypi✓ verified 24d ago

Flupy is a lightweight Python library and command-line interface (CLI) for implementing data pipelines with a fluent, chainable interface. Built upon generators, it processes data lazily and uses a constant amount of memory, making it suitable for large datasets. The current stable version is 1.2.3, and it maintains an active development cadence.

data workflow

pip install flupy

github ↗package ↗

INSTALL

IMPORT

SIG · FLUPY

flupy

datapythonv1.2.4

Install

1.6s avg

Import

114ms

Disk

16MB

Pass rate

10/ 10

Env Coverage10 / 10

glibc

3.9–3.13

musl

3.9–3.13

Install & Compatibility

Where this runs

tested against v1.2.4 · pip install

no network on importno background threads

Install × environment matrix

Each cell = how many times install + import succeeded across repeated harness runs. Partial = flaky.
glibc = Debian/Ubuntu slim · musl = Alpine Linux

musl

py 3.10–3.95 runs

installs and imports cleanly · install 0.0s · import 0.118s · 17.9MB

glibc

py 3.10–3.95 runs

installs and imports cleanly · install 1.6s · import 0.110s · 18MB

16MB installed

● package 16MB

Code

Verified usage

Verified import paths — ran on the pinned version, not inferred.

flu

✓ from flupy import flu

This example demonstrates creating a fluent pipeline to process an infinite sequence lazily, squaring numbers, filtering them, chunking the results, and taking a limited number of chunks. Operations are chained, with each method returning a new `flu` object.

from itertools import count from flupy import flu # Example: Process an infinite sequence in constant memory pipeline = ( flu(count()) # Start with an infinite sequence .map(lambda x: x**2) # Square each number .filter(lambda x: x % 517 == 0) # Keep only multiples of 517 .chunk(5) # Group into chunks of 5 .take(3) # Take the first 3 chunks ) results = [] for item in pipeline: results.append(item) print(results) # Expected output (varies slightly based on iteration start, but structure is similar): # [[0, 267289, 1069156, 2405601, 4276624], [6682225, 9622404, 13097161, 17106496, 21650409], [26728900, 32341969, 38489616, 45171841, 52388644]]

flupy --version

Debug

Known issues

gotchaFlupy pipelines are built on generators and evaluate lazily. Operations return new generators, and data is only processed when explicitly iterated over (e.g., in a `for` loop or by calling `.collect()`). If you assign a pipeline to a variable and iterate it once, then try to iterate the same variable again, it will be exhausted and yield no further results unless re-initialized.

fix

To re-run a pipeline or process data again, re-create the `flu` object from the original data source or explicitly `list()` the results of the first iteration if you need to reuse them.

affects: <=1.2.3

gotchaMethods on the `flu` object (like `.map()`, `.filter()`) return *new* `flu` instances, reflecting a functional programming paradigm. They do not modify the original iterable in-place. Attempting to modify the original source indirectly through chained methods will not work as expected.

fix

Always use the new `flu` object returned by each method call to continue the pipeline. If you need a final, concrete collection, use terminal operations like `.collect()` or `list()`.

affects: <=1.2.3

gotchaThe `flupy` library has an accompanying command-line interface (CLI) named `flu`. In the CLI, input data is automatically assigned to a variable named `_`. This `_` variable is specific to the CLI context and should not be directly used or confused with the `flu` object when writing Python code.

fix

When writing Python code, always explicitly import `flu` using `from flupy import flu` and initialize it with your iterable (e.g., `flu(my_list)`).

affects: <=1.2.3

Errors

Common errors & fixes

ModuleNotFoundError: No module named 'flupy'

The 'flupy' library is not installed in the current Python environment or the Python interpreter cannot find it in its search path.

fix

Install the library using pip: `pip install flupy`

TypeError: 'X' object is not iterable

This often occurs in flupy pipelines if a generator is exhausted by a previous iteration, or if a non-iterable object (like an integer or NoneType) is passed to a flupy method that expects an iterable.

fix

Ensure that if a `flu` pipeline is iterated, it is re-initialized from the original data source for subsequent iterations, or the results of the first iteration are collected into a list. Also, verify that all intermediate steps in the pipeline produce iterable outputs if required by the next step.

AttributeError: 'list' object has no attribute 'map'

This error arises when trying to call flupy's fluent methods (like `.map()`, `.filter()`) directly on a standard Python list or other iterable without first wrapping it with `flu()`. The methods are part of the `flu` object, not built-in list methods.

fix

Wrap your iterable with `flu()` before chaining methods: `flu(my_list).map(lambda x: x * 2)`

ImportError: cannot import name 'flu' from 'flupy'

This typically happens if there is a capitalization mistake in the import statement or if 'flu' is not directly exported from the top-level 'flupy' package in the way it's being imported. The correct import is `from flupy import flu`.

fix

Ensure the import statement is `from flupy import flu` with correct casing for both 'flupy' and 'flu'.

Upgrade

Version history

1.2.4latest on PyPI · released Jul 18, 2026

Audit

Dependencies

No dependency data recorded yet.

Agent activity

18 hits · last 30 days

node

OpenAI (training)

Resources

githubhttps://github.com/olirice/flupy ↗

packagehttps://pypi.org/project/flupy/ ↗