Basic Examples

This section contains basic examples to get you started with the Kailash Python SDK.

Simple Data Processing

from kailash.workflow import Workflow
from kailash.nodes.data import CSVReaderNode, CSVWriterNode
from kailash.runtime.local import LocalRuntime

# Create workflow
workflow = Workflow("simple_processing", name="Simple Processing")

# Add nodes
reader = CSVReaderNode(file_path="input.csv")
writer = CSVWriterNode(file_path="output.csv")

workflow.add_node("read", reader)
workflow.add_node("write", writer)

# Connect nodes
workflow.connect("read", "write")

# Execute
with LocalRuntime() as runtime:
    results, run_id = runtime.execute(workflow)

For more examples, see the examples directory.