Skip to content

Commit

Permalink
jobs: remove extraneous go
Browse files Browse the repository at this point in the history
Release note: None
  • Loading branch information
tbg committed Jan 22, 2021
1 parent baf34b2 commit 8854d95
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion pkg/jobs/jobs.go
Original file line number Diff line number Diff line change
Expand Up @@ -902,7 +902,7 @@ func (sj *StartableJob) Run(ctx context.Context) error {
case <-ctx.Done():
// Launch a goroutine to continue consuming results from the job.
if resultsFromJob != nil {
go sj.registry.stopper.RunWorker(ctx, func(ctx context.Context) {
sj.registry.stopper.RunWorker(ctx, func(ctx context.Context) {
for {
select {
case <-errCh:
Expand Down

0 comments on commit 8854d95

Please sign in to comment.