diff --git a/examples/dag.go b/examples/dag.go index 0dc5de4..d7371f7 100644 --- a/examples/dag.go +++ b/examples/dag.go @@ -30,7 +30,6 @@ func setup(f *dag.DAG) { AddNode("Store data", "store:data", &tasks.StoreData{Operation: services.Operation{Type: "process"}}). AddNode("Send SMS", "send:sms", &tasks.SendSms{Operation: services.Operation{Type: "process"}}). AddNode("Notification", "notification", &tasks.InAppNotification{Operation: services.Operation{Type: "process"}}). - AddNode("Data Branch", "data-branch", &tasks.DataBranchHandler{Operation: services.Operation{Type: "condition"}}). AddCondition("condition", map[dag.When]dag.Then{"pass": "email:deliver", "fail": "store:data"}). AddEdge("Get input to loop", "get:input", "loop"). AddIterator("Loop to prepare email", "loop", "prepare:email").