summaryrefslogtreecommitdiff
path: root/pkg/pool/supervisor_pool.go
diff options
context:
space:
mode:
authorValery Piashchynski <[email protected]>2021-02-02 19:30:00 +0300
committerGitHub <[email protected]>2021-02-02 19:30:00 +0300
commit20a1a5d2eb26090e0eef0e6772330ee2a52526fa (patch)
treec282e18c20029f60a798576cb4fe47d2762ffba0 /pkg/pool/supervisor_pool.go
parent36f01dc035f42115fcfd3b77dc5df3098382cd9f (diff)
parent2bdf7fafa73cabf7cf63657a6b58f2a423ae0fcd (diff)
Merge pull request #522 from spiral/fix/named_loggerv2.0.0-beta.22
bug(logger): Incorrect parsing of nested log levels
Diffstat (limited to 'pkg/pool/supervisor_pool.go')
-rwxr-xr-xpkg/pool/supervisor_pool.go6
1 files changed, 3 insertions, 3 deletions
diff --git a/pkg/pool/supervisor_pool.go b/pkg/pool/supervisor_pool.go
index 2597b352..3347ecd4 100755
--- a/pkg/pool/supervisor_pool.go
+++ b/pkg/pool/supervisor_pool.go
@@ -6,9 +6,9 @@ import (
"time"
"github.com/spiral/errors"
- "github.com/spiral/roadrunner/v2/internal"
"github.com/spiral/roadrunner/v2/pkg/events"
"github.com/spiral/roadrunner/v2/pkg/payload"
+ "github.com/spiral/roadrunner/v2/pkg/states"
"github.com/spiral/roadrunner/v2/pkg/worker"
"github.com/spiral/roadrunner/v2/tools"
)
@@ -144,7 +144,7 @@ func (sp *supervised) control() {
workers := sp.pool.Workers()
for i := 0; i < len(workers); i++ {
- if workers[i].State().Value() == internal.StateInvalid {
+ if workers[i].State().Value() == states.StateInvalid {
continue
}
@@ -177,7 +177,7 @@ func (sp *supervised) control() {
// firs we check maxWorker idle
if sp.cfg.IdleTTL != 0 {
// then check for the worker state
- if workers[i].State().Value() != internal.StateReady {
+ if workers[i].State().Value() != states.StateReady {
continue
}