summaryrefslogtreecommitdiff
path: root/pkg/pool
diff options
context:
space:
mode:
authorValery Piashchynski <[email protected]>2020-12-20 19:26:20 +0300
committerValery Piashchynski <[email protected]>2020-12-20 19:26:20 +0300
commit5de1375c28790c24cfdaec55961a4da5800c6e09 (patch)
treebc53724c7514dcb5c901958097a6f2e7c4531ba9 /pkg/pool
parentf4a36c7f684216fb408693a6c494486144df57cf (diff)
Resolve merge conflict
Diffstat (limited to 'pkg/pool')
-rwxr-xr-xpkg/pool/static_pool.go8
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