pip install rainbowflow
python
from rainbowflow import Flow
flow = Flow()
def process_data(data):
processed_data = data * 2
return processed_data
def generate_data():
data = [1, 2, 3, 4, 5]
return data
def output_data(data):
print(data)
flow.source(generate_data)
flow.process(process_data)
flow.sink(output_data)
flow.start()
