Skip to content

Commit

Permalink
address
Browse files Browse the repository at this point in the history
Signed-off-by: nolouch <[email protected]>
  • Loading branch information
nolouch committed Apr 15, 2024
1 parent d85ac59 commit 85e6950
Show file tree
Hide file tree
Showing 2 changed files with 1 addition and 2 deletions.
2 changes: 1 addition & 1 deletion pkg/core/context.go
Original file line number Diff line number Diff line change
Expand Up @@ -29,7 +29,7 @@ type MetaProcessContext struct {
}

// NewMetaProcessContext creates a new MetaProcessContext.
// used in tests.
// used in tests, can be changed if no need to test concurrency.
func ContextTODO() *MetaProcessContext {
return &MetaProcessContext{
Context: context.TODO(),
Expand Down
1 change: 0 additions & 1 deletion pkg/ratelimit/runner.go
Original file line number Diff line number Diff line change
Expand Up @@ -85,7 +85,6 @@ func (s *ConcurrentRunner) Start() {
if task.Opts.Limit != nil {
token, err := task.Opts.Limit.Acquire(context.Background())
if err != nil {
log.Error("failed to acquire semaphore", zap.String("task-name", task.Opts.TaskName), zap.Error(err))
continue
}
go s.run(task.Ctx, task.f, token)
Expand Down

0 comments on commit 85e6950

Please sign in to comment.