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 19f6d0a commit 3f14d95Copy full SHA for 3f14d95
internal/worker/activity.go
@@ -116,7 +116,7 @@ func (aw *activityWorker) runDispatcher(ctx context.Context) {
116
func (aw *activityWorker) handleTask(ctx context.Context, task *task.Activity) {
117
// Start heartbeat while activity is running
118
heartbeatCtx, cancelHeartbeat := context.WithCancel(ctx)
119
- go func(ctx context.Context) {=
+ go func(ctx context.Context) {
120
t := time.NewTicker(aw.options.ActivityHeartbeatInterval)
121
defer t.Stop()
122
0 commit comments