package/mq
1
0
Fork 0
mirror of https://github.com/oarkflow/mq.git synced 2025-10-05 16:06:55 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

update: dependencies

Browse Source
This commit is contained in:
Oarkflow
2024-11-16 16:07:58 +05:45
parent 3bfd26c8ed
commit 0a4dd7bd58
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
examples/dag.go
View File

@@ -25,7 +25,8 @@ func subDAG() *dag.DAG {
AddNode("Store data", "store:data", &tasks.StoreData{Operation: dag.Operation{Type: "process"}}, true).
AddNode("Send SMS", "send:sms", &tasks.SendSms{Operation: dag.Operation{Type: "process"}}).
AddNode("Notification", "notification", &tasks.InAppNotification{Operation: dag.Operation{Type: "process"}}).
AddEdge("Store Data to send sms and notification", "store:data", "send:sms", "notification")
AddEdge("Store Data to send sms", "store:data", "send:sms").
AddEdge("Store Data to notification", "send:sms", "notification")
return f
}