projects
/
arvados.git
/ commitdiff
summary
|
shortlog
|
log
|
commit
| commitdiff |
tree
raw
|
patch
| inline |
side by side
(parent:
d258e5c
)
14920: Update metrics when worker state changes idle->running.
author
Tom Clegg <tclegg@veritasgenetics.com>
Thu, 7 Mar 2019 19:27:13 +0000
(14:27 -0500)
committer
Tom Clegg <tclegg@veritasgenetics.com>
Thu, 7 Mar 2019 19:27:13 +0000
(14:27 -0500)
Arvados-DCO-1.1-Signed-off-by: Tom Clegg <tclegg@veritasgenetics.com>
lib/dispatchcloud/worker/worker.go
patch
|
blob
|
history
diff --git
a/lib/dispatchcloud/worker/worker.go
b/lib/dispatchcloud/worker/worker.go
index 9be9f41f43b7ef51cbb1d1257e4ac39f642472aa..64e1f7797af8634be63502faea5faaaa8b30a5f9 100644
(file)
--- a/
lib/dispatchcloud/worker/worker.go
+++ b/
lib/dispatchcloud/worker/worker.go
@@
-101,7
+101,10
@@
func (wkr *worker) startContainer(ctr arvados.Container) {
logger = logger.WithField("Instance", wkr.instance.ID())
logger.Debug("starting container")
wkr.starting[ctr.UUID] = struct{}{}
- wkr.state = StateRunning
+ if wkr.state != StateRunning {
+ wkr.state = StateRunning
+ go wkr.wp.notify()
+ }
go func() {
env := map[string]string{
"ARVADOS_API_HOST": wkr.wp.arvClient.APIHost,