Some more

cschleiden · web-flow · commit 692983f2374d · 2022-06-21T04:24:42.000Z
diff --git a/internal/workflow/workflow.go b/internal/workflow/workflow.go
@@ -81,11 +81,11 @@ func (w *workflow) Execute(ctx sync.Context, inputs []payload.Payload) error {
 		return nil
 	})
 
-	return w.s.Execute(ctx)
+	return w.s.Execute()
 }
 
-func (w *workflow) Continue(ctx sync.Context) error {
-	return w.s.Execute(ctx)
+func (w *workflow) Continue() error {
+	return w.s.Execute()
 }
 
 func (w *workflow) Completed() bool {
@@ -102,7 +102,7 @@ func (w *workflow) Error() error {
 	return w.err
 }
 
-func (w *workflow) Close(ctx sync.Context) {
+func (w *workflow) Close() {
 	// End coroutine execution to prevent goroutine leaks
-	w.s.Exit(ctx)
+	w.s.Exit()
 }

Original file line number	Diff line number	Diff line change
`@@ -81,11 +81,11 @@ func (w *workflow) Execute(ctx sync.Context, inputs []payload.Payload) error {`
`81`	`81`	`return nil`
`82`	`82`	`})`
`83`	`83`
`84`		`- return w.s.Execute(ctx)`
	`84`	`+ return w.s.Execute()`
`85`	`85`	`}`
`86`	`86`
`87`		`-func (w *workflow) Continue(ctx sync.Context) error {`
`88`		`- return w.s.Execute(ctx)`
	`87`	`+func (w *workflow) Continue() error {`
	`88`	`+ return w.s.Execute()`
`89`	`89`	`}`
`90`	`90`
`91`	`91`	`func (w *workflow) Completed() bool {`
`@@ -102,7 +102,7 @@ func (w *workflow) Error() error {`
`102`	`102`	`return w.err`
`103`	`103`	`}`
`104`	`104`
`105`		`-func (w *workflow) Close(ctx sync.Context) {`
	`105`	`+func (w *workflow) Close() {`
`106`	`106`	`// End coroutine execution to prevent goroutine leaks`
`107`		`- w.s.Exit(ctx)`
	`107`	`+ w.s.Exit()`
`108`	`108`	`}`