Skip to content

Commit

Permalink
fix
Browse files Browse the repository at this point in the history
  • Loading branch information
kevindiu authored and actions-user committed Aug 3, 2020
1 parent 7270c7d commit ca8f5f0
Showing 1 changed file with 2 additions and 1 deletion.
3 changes: 2 additions & 1 deletion internal/worker/worker.go
Original file line number Diff line number Diff line change
Expand Up @@ -81,7 +81,8 @@ func New(opts ...WorkerOption) (Worker, error) {
return w, nil
}

// Start starts execute jobs in the worker queue. It returns the error channel that the job return, and the error if start failed.
// Start starts execute jobs in the worker queue.
// It returns the error channel that the job return, and the error if start failed.
func (w *worker) Start(ctx context.Context) (<-chan error, error) {
if w.IsRunning() {
return nil, errors.ErrWorkerIsAlreadyRunning(w.Name())
Expand Down

0 comments on commit ca8f5f0

Please sign in to comment.