Registry / data / fugue
library0.9.7pypypi✓ verified 25d ago

Fugue is a Python library that provides a unified interface for defining data workflows, allowing them to run seamlessly on Pandas, Spark, Dask, Ray, and other distributed computing engines without code changes. It's designed to make data pipelines more portable and testable. The current version is 0.9.7, and it maintains an active release cadence with frequent patches and updates.

pip install fugue
INSTALL
IMPORT
SIG · FUGUE
F
fugue
datapythonv0.9.7
Install
19.4s avg
Import
1687ms
Disk
828MB
Pass rate
5/ 10
Env Coverage5 / 10
glibc
3.93.13
musl
3.93.13
Install & Compatibility
Where this runs
tested against v0.9.7 · 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
glibc
py 3.10
3/5 runs
✓ 19.74s
py 3.11
3/5 runs
✓ 18.46s
py 3.12
3/5 runs
✓ 19.04s
py 3.13
3/5 runs
✓ 18.54s
py 3.9
4/5 runs
✓ 21.12s
828MB installed
● package 828MB
Code
Verified usage

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

FugueWorkflow
from fugue import FugueWorkflow
from fugue import FugueWorkflow

This quickstart demonstrates defining a simple Fugue workflow. It creates a DataFrame, applies a transformation function (`map_to_string`) that converts a numeric column to a string, and then executes the workflow, printing the result to the console. The `schema` parameter in `transform` is crucial for explicit schema definition.

from fugue import FugueWorkflow import pandas as pd def map_to_string(df: pd.DataFrame) -> pd.DataFrame: return df.assign(value_str=df['value'].astype(str)) with FugueWorkflow() as dag: df = dag.df([{"id": 1, "value": 10}, {"id": 2, "value": 20}]) result = df.transform(map_to_string, schema="*,value_str:str") result.show()
fugue --version
Debug
Known issues
breakingFugue SQL and related functions/dependencies were moved to an optional `[sql]` extra package in version 0.9.0. Users relying on these features without explicit installation will encounter `ImportError`.
fix
Ensure `fugue[sql]` is installed: `pip install 'fugue[sql]'`.
affects: >=0.9.0
gotchaFugue has strict Python version requirements. From 0.9.0 onwards, it generally requires Python 3.10 or higher. Using older Python versions will lead to installation and runtime errors.
fix
Upgrade your Python environment to 3.10 or newer.
affects: >=0.9.0
gotchaThere have been several patches related to Pandas compatibility (e.g., specific version pinning for Pandas<3, then unpinning). Users might face issues if their Pandas version is incompatible with the installed Fugue version, especially when using Pandas 2.x.
fix
Always install Fugue with its recommended extras (e.g., `pip install fugue[spark]`) to ensure compatible dependency versions are pulled. If issues persist, try upgrading/downgrading Pandas to align with Fugue's tested range or refer to Fugue's release notes for specific constraints.
affects: 0.9.4 - 0.9.5 (and potentially others)
deprecatedThe `DataFrame` class was moved from `fugue.dataframe` to `fugue.collections.dataframe`. While the old path might still work for some time due to redirects, it's considered deprecated.
fix
Update imports from `from fugue.dataframe import DataFrame` to `from fugue.collections.dataframe import DataFrame`.
affects: >=0.9.0
gotchaCompatibility with distributed engines (Spark, Ray, Dask) is continuously updated. Older Fugue versions might not work with the latest versions of these engines, and vice-versa. Users should monitor Fugue release notes for compatibility fixes.
fix
Keep Fugue updated to the latest patch version alongside your distributed engine. If specific compatibility issues arise, check the Fugue GitHub issues or documentation for known conflicts.
affects: All versions
Upgrade
Version history
0.9.7latest on PyPI · released Feb 20, 2026
Audit
Dependencies
pandasrequiredCore data structure compatibility; specific versions may cause issues.
pysparkoptionalRequired for Spark backend functionality.
daskoptionalRequired for Dask backend functionality.
rayoptionalRequired for Ray backend functionality.
Agent activity
20 hits · last 30 days
node
18
OpenAI (training)
1
Resources
fugue — pip install fugue · libregistry