We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 2a1a363 commit 297234fCopy full SHA for 297234f
backend/monoprocess/monoprocess.go
@@ -105,7 +105,9 @@ func (b *monoprocessBackend) CompleteWorkflowTask(
105
// Note that the worker will be notified even if the timer event gets
106
// cancelled. This is ok, because the poller will simply find no task
107
// and continue.
108
- time.AfterFunc(attr.At.Sub(time.Now()), func() { b.notifyWorkflowWorker(context.Background()) })
+ time.AfterFunc(time.Until(attr.At), func() {
109
+ b.notifyWorkflowWorker(ctx)
110
+ })
111
}
112
113
b.notifyWorkflowWorker(ctx)
0 commit comments