Reduce the capacity of signal channels

cschleiden · cschleiden · commit 156d31719394 · 2022-07-26T22:10:29.000Z
diff --git a/internal/workflowstate/signalchannels.go b/internal/workflowstate/signalchannels.go
@@ -30,7 +30,7 @@ func GetSignalChannel[T any](ctx sync.Context, wf *WfState, name string) sync.Ch
 	}
 
 	// Otherwise, create new channel
-	c := sync.NewBufferedChannel[T](10_000)
+	c := sync.NewBufferedChannel[T](100)
 
 	// Add channel to map
 	wf.signalChannels[name] = &signalChannel{

Original file line number	Diff line number	Diff line change
`@@ -30,7 +30,7 @@ func GetSignalChannel[T any](ctx sync.Context, wf *WfState, name string) sync.Ch`
`30`	`30`	`}`
`31`	`31`
`32`	`32`	`// Otherwise, create new channel`
`33`		`- c := sync.NewBufferedChannel[T](10_000)`
	`33`	`+ c := sync.NewBufferedChannel[T](100)`
`34`	`34`
`35`	`35`	`// Add channel to map`
`36`	`36`	`wf.signalChannels[name] = &signalChannel{`