Bubbles 0.3 (prototype 3) feature preview

bubbles-p3.py

from bubbles import Pipeline, ExecutionEngine
from bubbles import operation, datasource

# New implicit iterator operations

@datasource(fields=["i"])
def generator(context, count=10):
    for i in range(count):
        yield [i]


@operation
def add(context, src, amount=1):
    for row in src:
        yield [row[0]+amount] + row[1:]


@operation
def pretty_print(context, src):
    for row in src:
        print(row)


# New generative interface
p = Pipeline()
p.generator().add(amount=10).pretty_print()


# Execution responsibility moved to extensible/replacable execution engine
e = ExecutionEngine()
e.run(p.graph)