Pydra dataflow engine
Project description
Pydra: Dataflow Engine
A simple dataflow engine with scalable semantics.
Pydra is a rewrite of the Nipype engine with mapping and joining as first-class operations. It forms the core of the Nipype 2.0 ecosystem.
The goal of pydra is to provide a lightweight Python dataflow engine for DAG construction, manipulation, and distributed execution.
Feature list:
Python 3.7+ using type annotation and attrs
Composable dataflows with simple node semantics. A dataflow can be a node of another dataflow.
splitter and combiner provides many ways of compressing complex loop semantics
Cached execution with support for a global cache across dataflows and users
Distributed execution, presently via ConcurrentFutures, SLURM, and Dask (this is an experimental implementation with limited testing)
Learn more about Pydra
Explore Pydra interactively (the tutorial can be also run using Binder service)
Please note that mybinder times out after an hour.
Installation
pip install pydra
Note that installation fails with older versions of pip on Windows. Upgrade pip before installing:
pip install –upgrade pip pip install pydra
Developer installation
Pydra requires Python 3.7+. To install in developer mode:
git clone git@github.com:nipype/pydra.git cd pydra pip install -e .[dev]
In order to run pydra’s test locally:
pytest -vs pydra
If you want to test execution with Dask:
git clone git@github.com:nipype/pydra.git cd pydra pip install -e .[dask]
It is also useful to install pre-commit:
pip install pre-commit pre-commit
Release history Release notifications | RSS feed
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distributions
Built Distribution
Filter files by name, interpreter, ABI, and platform.
If you're not sure about the file name format, learn more about wheel file names.
Copy a direct link to the current filters
File details
Details for the file pydra-0.9.2-py3-none-any.whl.
File metadata
- Download URL: pydra-0.9.2-py3-none-any.whl
- Upload date:
- Size: 149.8 kB
- Tags: Python 3
- Uploaded using Trusted Publishing? No
- Uploaded via: twine/3.2.0 pkginfo/1.5.0.1 requests/2.24.0 setuptools/47.1.0 requests-toolbelt/0.9.1 tqdm/4.49.0 CPython/3.8.5
File hashes
| Algorithm | Hash digest | |
|---|---|---|
| SHA256 |
2f170e67106c8946ee139a6faba2d89ec79be4a2017c385c2a0f06440ec6723d
|
|
| MD5 |
6a2e85ad7d3e6229007e878937afd4a9
|
|
| BLAKE2b-256 |
35f07be7da7ffde65e7839211320a90b4b0681bbda559d87611ed84595b94641
|
