[skip ci] fix cal init error

projecteru2 · Jul 6, 2022 · bc68b11 · bc68b11
1 parent e343332
commit bc68b11
Showing 1 changed file with 8 additions and 1 deletion.
diff --git a/cluster/calcium/calcium.go b/cluster/calcium/calcium.go
@@ -90,7 +90,14 @@ func New(config types.Config, t *testing.T) (*Calcium, error) {
 	cal := &Calcium{store: store, config: config, source: scm, watcher: watcher, resource: resource}
 
 	cal.wal, err = newWAL(config, cal)
-	cal.identifier = config.Identifier()
+	if err != nil {
+		return nil, logger.ErrWithTracing(nil, errors.WithStack(err)) //nolint
+	}
+
+	cal.identifier, err = config.Identifier()
+	if err != nil {
+		return nil, logger.ErrWithTracing(nil, errors.WithStack(err)) //nolint
+	}
 
 	go cal.InitMetrics()