err check

IBM-Cloud · May 16, 2024 · d622871 · d622871
1 parent 8337f7a
commit d622871
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 2 deletions.
diff --git a/rules/engine.go b/rules/engine.go
@@ -268,7 +268,10 @@ func (e *v3Engine) AddPolling(namespacePattern string, preconditions DynamicRule
 		lease:          e.cl,
 		engine:         e,
 	}
-	e.AddRule(rule, "/rule_locks"+namespacePattern+"lock", cbw.doRule, RuleID(namespacePattern))
+	err = e.AddRule(rule, "/rule_locks"+namespacePattern+"lock", cbw.doRule, RuleID(namespacePattern))
+	if err != nil {
+		return err
+	}
 	return nil
 }
 

diff --git a/v3enginetest/main.go b/v3enginetest/main.go
@@ -170,12 +170,13 @@ func main() {
 	doneFalse := "false"
 	doneRule, err := rules.NewEqualsLiteralRule(donePath, &doneFalse)
 	check(err)
-	engine.AddRule(doneRule, "/rulesEngineDone/:id", func(task *rules.V3RuleTask) {
+	err = engine.AddRule(doneRule, "/rulesEngineDone/:id", func(task *rules.V3RuleTask) {
 		path := task.Attr.Format(donePath)
 		doneTrue := "true"
 		_, err := kv.Put(task.Context, path, doneTrue)
 		check(err)
 	}, rules.RuleID(doneRuleID))
+	check(err)
 
 	engine.Run()
 	time.Sleep(time.Second)