From d25acd6794de48d6927cd5d6250cedef3ba4e2d1 Mon Sep 17 00:00:00 2001 From: Tom Clegg Date: Mon, 15 Aug 2016 16:58:02 -0400 Subject: [PATCH] 9706: Notify systemd when crunch-dispatch-slurm is ready. --- services/crunch-dispatch-slurm/crunch-dispatch-slurm.go | 5 +++++ services/crunch-dispatch-slurm/crunch-dispatch-slurm.service | 2 +- 2 files changed, 6 insertions(+), 1 deletion(-) diff --git a/services/crunch-dispatch-slurm/crunch-dispatch-slurm.go b/services/crunch-dispatch-slurm/crunch-dispatch-slurm.go index 1d9015d505..8686fa4284 100644 --- a/services/crunch-dispatch-slurm/crunch-dispatch-slurm.go +++ b/services/crunch-dispatch-slurm/crunch-dispatch-slurm.go @@ -9,6 +9,7 @@ import ( "git.curoverse.com/arvados.git/sdk/go/arvados" "git.curoverse.com/arvados.git/sdk/go/arvadosclient" "git.curoverse.com/arvados.git/sdk/go/dispatch" + "github.com/coreos/go-systemd/daemon" "io" "io/ioutil" "log" @@ -105,6 +106,10 @@ func doMain() error { PollInterval: time.Duration(config.PollPeriod), DoneProcessing: make(chan struct{})} + if _, err := daemon.SdNotify("READY=1"); err != nil { + log.Printf("Error notifying init daemon: %v", err) + } + err = dispatcher.RunDispatcher() if err != nil { return err diff --git a/services/crunch-dispatch-slurm/crunch-dispatch-slurm.service b/services/crunch-dispatch-slurm/crunch-dispatch-slurm.service index eac8d89db2..5b37e3c0a3 100644 --- a/services/crunch-dispatch-slurm/crunch-dispatch-slurm.service +++ b/services/crunch-dispatch-slurm/crunch-dispatch-slurm.service @@ -4,7 +4,7 @@ Documentation=https://doc.arvados.org/ After=network.target [Service] -Type=simple +Type=notify ExecStart=/usr/bin/crunch-dispatch-slurm Restart=always -- 2.30.2