diff --git a/heat/db/api.py b/heat/db/api.py
index 27a9db3777..14ca76c29d 100644
--- a/heat/db/api.py
+++ b/heat/db/api.py
@@ -154,6 +154,10 @@ def watch_rule_get_all(context):
     return IMPL.watch_rule_get_all(context)
 
 
+def watch_rule_get_all_by_stack(context, stack_id):
+    return IMPL.watch_rule_get_all_by_stack(context, stack_id)
+
+
 def watch_rule_create(context, values):
     return IMPL.watch_rule_create(context, values)
 
diff --git a/heat/db/sqlalchemy/api.py b/heat/db/sqlalchemy/api.py
index cfcec42b07..57680b22a2 100644
--- a/heat/db/sqlalchemy/api.py
+++ b/heat/db/sqlalchemy/api.py
@@ -271,6 +271,12 @@ def watch_rule_get_all(context):
     return results
 
 
+def watch_rule_get_all_by_stack(context, stack_id):
+    results = model_query(context, models.WatchRule).\
+                          filter_by(stack_id=stack_id).all()
+    return results
+
+
 def watch_rule_create(context, values):
     obj_ref = models.WatchRule()
     obj_ref.update(values)