Find answers from the community

Updated 2 months ago

I am stuck on this. Lets say I have DAG

I am stuck on this. Lets say I have DAG query pipeline containing various nodes and edges. Now, depending on the value generated in node A, I have to redirect the control either to node B or node C but not both. How can I achieve this conditional control flow in DAG query pipeline. Thanks

2 comments

LLogan M

This is exactly what conditional links are for

pipeline.add_link("a", "b", condition_fn=lambda a_result: a_result["y"] > 10)

AAshish

Wow... Thanks!!

Add a reply