VOL-1774 Etcd Crash Handling
Change-Id: I1eeb726654c3972fd0a4fafae134607e5a810415
diff --git a/rw_core/core/device_agent_test.go b/rw_core/core/device_agent_test.go
index 8200ae7..b00c42c 100755
--- a/rw_core/core/device_agent_test.go
+++ b/rw_core/core/device_agent_test.go
@@ -112,8 +112,11 @@
cfg.GrpcHost = "127.0.0.1"
setCoreCompeteMode(inCompeteMode)
client := setupKVClient(cfg, dat.coreInstanceID)
- dat.core = NewCore(dat.coreInstanceID, cfg, client, dat.kClient)
- dat.core.Start(context.Background())
+ dat.core = NewCore(context.Background(), dat.coreInstanceID, cfg, client, dat.kClient)
+ err = dat.core.Start(context.Background())
+ if err != nil {
+ log.Fatal("Cannot start core")
+ }
}
func (dat *DATest) stopAll() {