From 9bfc28c291709bec13b5d4a9f899587315e4ee9e Mon Sep 17 00:00:00 2001 From: Isabel Jimenez Date: Tue, 12 Jan 2016 16:48:32 -0500 Subject: [PATCH] Adding obeserve async for driver abort/errors Signed-off-by: Isabel Jimenez --- cluster/mesos/cluster.go | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/cluster/mesos/cluster.go b/cluster/mesos/cluster.go index 18f3c4cae8..1b4b60a5a0 100644 --- a/cluster/mesos/cluster.go +++ b/cluster/mesos/cluster.go @@ -148,6 +148,12 @@ func NewCluster(scheduler *scheduler.Scheduler, TLSConfig *tls.Config, master st } log.Debugf("Mesos driver started, status %v", status) + go func() { + status, err := sched.driver.Join() + log.Debugf("Mesos driver stopped unexpectedly, status/err %v: %v", status, err) + + }() + return cluster, nil }