From 24bb2336653f8f4d145ebbd1cb1649978cd54324 Mon Sep 17 00:00:00 2001 From: NoneBack <46670806+noneback@users.noreply.github.com> Date: Thu, 26 Sep 2024 20:22:25 +0800 Subject: [PATCH 1/2] Update readme.md --- readme.md | 57 ++++++++++++++++++++++++++++++++++++++++++++++++++----- 1 file changed, 52 insertions(+), 5 deletions(-) diff --git a/readme.md b/readme.md index a52781b..4c7f431 100644 --- a/readme.md +++ b/readme.md @@ -1,5 +1,10 @@ # Go-Taskflow -A DAG Task Computing Framework with taskflow-styled api. +A static DAG Task Computing Framework with taskflow-styled api. + +## Feature +- User-friendly programming interface +- Subflow supported +- DAG to dot visualization ## Example ```go @@ -8,6 +13,8 @@ package main import ( "context" "fmt" + "log" + "os" "runtime" gotaskflow "github.com/noneback/go-taskflow" @@ -43,10 +50,50 @@ func main() { C.Succeed(A1) C.Succeed(B1) - tf.Push(A, B, C) - tf.Push(A1, B1, C1) + subflow := gotaskflow.NewSubflow("sub1", func(sf *gotaskflow.Subflow) { + A2, B2, C2 := + gotaskflow.NewTask("A2", func(ctx *context.Context) { + fmt.Println("A2") + }), + gotaskflow.NewTask("B2", func(ctx *context.Context) { + fmt.Println("B2") + }), + gotaskflow.NewTask("C2", func(ctx *context.Context) { + fmt.Println("C2") + }) + A2.Precede(B2) + C2.Precede(B2) + sf.Push(A2, B2, C2) + }) + + subflow2 := gotaskflow.NewSubflow("sub2", func(sf *gotaskflow.Subflow) { + A3, B3, C3 := + gotaskflow.NewTask("A3", func(ctx *context.Context) { + fmt.Println("A3") + }), + gotaskflow.NewTask("B3", func(ctx *context.Context) { + fmt.Println("B3") + }), + gotaskflow.NewTask("C3", func(ctx *context.Context) { + fmt.Println("C3") + // time.Sleep(10 * time.Second) + }) + A3.Precede(B3) + C3.Precede(B3) + sf.Push(A3, B3, C3) + }) - executor.Run(tf).Wait() + subflow.Precede(B) + subflow.Precede(subflow2) + + tf := gotaskflow.NewTaskFlow("G") + tf.Push(A, B, C) + tf.Push(A1, B1, C1, subflow, subflow2) + exector.Run(tf) + exector.Wait() + if err := gotaskflow.Visualizer.Visualize(tf, os.Stdout); err != nil { + log.Fatal(err) + } } -``` \ No newline at end of file +``` From ec3edfce5f715fd47080c105aadef12ffafbb759 Mon Sep 17 00:00:00 2001 From: "dependabot[bot]" <49699333+dependabot[bot]@users.noreply.github.com> Date: Thu, 26 Sep 2024 12:24:17 +0000 Subject: [PATCH 2/2] chore(deps): bump golang.org/x/image from 0.14.0 to 0.18.0 Bumps [golang.org/x/image](https://github.com/golang/image) from 0.14.0 to 0.18.0. - [Commits](https://github.com/golang/image/compare/v0.14.0...v0.18.0) --- updated-dependencies: - dependency-name: golang.org/x/image dependency-type: indirect ... Signed-off-by: dependabot[bot] --- go.mod | 2 +- go.sum | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/go.mod b/go.mod index a0b6bb7..f2d333d 100644 --- a/go.mod +++ b/go.mod @@ -13,5 +13,5 @@ require ( github.com/golang/freetype v0.0.0-20170609003504-e2365dfdc4a0 // indirect github.com/google/pprof v0.0.0-20240227163752-401108e1b7e7 // indirect github.com/pkg/errors v0.9.1 // indirect - golang.org/x/image v0.14.0 // indirect + golang.org/x/image v0.18.0 // indirect ) diff --git a/go.sum b/go.sum index c4d770a..f16b27e 100644 --- a/go.sum +++ b/go.sum @@ -40,8 +40,8 @@ github.com/stretchr/objx v0.4.0/go.mod h1:YvHI0jy2hoMjB+UWwv71VJQ9isScKT/TqJzVSS github.com/stretchr/testify v1.7.1/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg= github.com/stretchr/testify v1.8.0 h1:pSgiaMZlXftHpm5L7V1+rVB+AZJydKsMxsQBIJw4PKk= github.com/stretchr/testify v1.8.0/go.mod h1:yNjHg4UonilssWZ8iaSj1OCr/vHnekPRkoO+kdMU+MU= -golang.org/x/image v0.14.0 h1:tNgSxAFe3jC4uYqvZdTr84SZoM1KfwdC9SKIFrLjFn4= -golang.org/x/image v0.14.0/go.mod h1:HUYqC05R2ZcZ3ejNQsIHQDQiwWM4JBqmm6MKANTp4LE= +golang.org/x/image v0.18.0 h1:jGzIakQa/ZXI1I0Fxvaa9W7yP25TqT6cHIHn+6CqvSQ= +golang.org/x/image v0.18.0/go.mod h1:4yyo5vMFQjVjUcVk4jEQcU9MGy/rulF5WvUILseCM2E= golang.org/x/sys v0.0.0-20220310020820-b874c991c1a5/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= golang.org/x/sys v0.6.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=