14920: Update metrics when worker state changes idle->running.
authorTom Clegg <tclegg@veritasgenetics.com>
Thu, 7 Mar 2019 19:27:13 +0000 (14:27 -0500)
committerTom 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

index 9be9f41f43b7ef51cbb1d1257e4ac39f642472aa..64e1f7797af8634be63502faea5faaaa8b30a5f9 100644 (file)
@@ -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,