Simple pipelines building framework.
Project description
- [=|Pipeless|=] provides a simple framework
for building a data pipeline.
It’s an advanced version of this: function4(function3(function2(function1(0))))
It looks like this:
>>> function, run, _ = pipeline(lambda item, e: None) >>> @function ... def up_one(): return lambda item: item+1 >>> list(run([0, 1, 3])) [1, 2, 4] >>> @function ... def twofer(): return lambda item: [item, item] >>> list(run([0, 1, 3])) [1, 1, 2, 2, 4, 4]
Pipelines operate over sources
Functions can return 1 Item, None to drop the item, or a generator to expand the item.
Also provides a simple Optionally-Argumented NamedTuple and a Commmand Line Generator.
Project details
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
Pipeless-1.0.1.zip
(4.3 kB
view hashes)