graph = StateGraph()
graph.add_node('ingest', ingest_step)
graph.add_node('clean', clean_step)
graph.add_node('analyze', analyze_step)
# ...
add_edge(graph, 'ingest', 'clean')
add_edge(graph, 'clean', 'analyze')
# ...

output = graph.run({'source': 's3_bucket', ...})