diff options
author | Valery Piashchynski <[email protected]> | 2020-12-20 19:26:20 +0300 |
---|---|---|
committer | Valery Piashchynski <[email protected]> | 2020-12-20 19:26:20 +0300 |
commit | 5de1375c28790c24cfdaec55961a4da5800c6e09 (patch) | |
tree | bc53724c7514dcb5c901958097a6f2e7c4531ba9 /pkg/pool | |
parent | f4a36c7f684216fb408693a6c494486144df57cf (diff) |
Resolve merge conflict
Diffstat (limited to 'pkg/pool')
-rwxr-xr-x | pkg/pool/static_pool.go | 8 |
1 files changed, 7 insertions, 1 deletions
diff --git a/pkg/pool/static_pool.go b/pkg/pool/static_pool.go index 9cf79fd4..e5a5a7e8 100755 --- a/pkg/pool/static_pool.go +++ b/pkg/pool/static_pool.go @@ -346,7 +346,13 @@ func (sp *StaticPool) allocateWorkers(ctx context.Context, numWorkers int64) ([] cancel() return nil, errors.E(op, errors.WorkerAllocate, err) } - workers = append(workers, w) + + sw, err := syncWorker.From(w) + if err != nil { + cancel() + return nil, errors.E(op, err) + } + workers = append(workers, sw) cancel() } return workers, nil |