diff --git a/api/chalicelib/core/alerts_processor.py b/api/chalicelib/core/alerts_processor.py
index 4fd7f27ec..e4579826f 100644
--- a/api/chalicelib/core/alerts_processor.py
+++ b/api/chalicelib/core/alerts_processor.py
@@ -104,7 +104,7 @@ def Build(a):
         a["filter"]["endDate"] = TimeUTC.now()
         full_args, query_part, sort = sessions.search_query_parts(
             data=schemas.SessionsSearchPayloadSchema.parse_obj(a["filter"]), error_status=None, errors_only=False,
-            issue=None, project_id=a["projectId"], user_id=None)
+            issue=None, project_id=a["projectId"], user_id=None, favorite_only=False)
         subQ = f"""SELECT COUNT(session_id) AS value 
                 {query_part}"""
     else:
diff --git a/api/chalicelib/core/sessions.py b/api/chalicelib/core/sessions.py
index b213a55f6..aafa00570 100644
--- a/api/chalicelib/core/sessions.py
+++ b/api/chalicelib/core/sessions.py
@@ -170,7 +170,9 @@ def _isUndefined_operator(op: schemas.SearchEventOperator):
 @dev.timed
 def search2_pg(data: schemas.SessionsSearchPayloadSchema, project_id, user_id, errors_only=False,
                error_status="ALL", count_only=False, issue=None):
-    full_args, query_part, sort = search_query_parts(data, error_status, errors_only, issue, project_id, user_id)
+    full_args, query_part, sort = search_query_parts(data=data, error_status=error_status, errors_only=errors_only,
+                                                     favorite_only=data.bookmarked, issue=issue, project_id=project_id,
+                                                     user_id=user_id)
     if data.limit is not None and data.page is not None:
         full_args["sessions_limit_s"] = (data.page - 1) * data.limit
         full_args["sessions_limit_e"] = data.page * data.limit
@@ -974,12 +976,12 @@ def search_query_parts(data, error_status, errors_only, favorite_only, issue, pr
             extra_from += " INNER JOIN public.user_favorite_errors AS ufe USING (error_id)"
             extra_constraints.append("ufe.user_id = %(userId)s")
     # extra_constraints = [extra.decode('UTF-8') + "\n" for extra in extra_constraints]
-    if data.bookmarked and not errors_only and user_id is not None:
+    if favorite_only and not errors_only and user_id is not None:
         extra_from += """INNER JOIN (SELECT user_id, session_id
                                     FROM public.user_favorite_sessions
                                     WHERE user_id = %(userId)s) AS favorite_sessions
                                     USING (session_id)"""
-    elif not data.bookmarked and not errors_only and user_id is not None:
+    elif not favorite_only and not errors_only and user_id is not None:
         extra_from += """LEFT JOIN (SELECT user_id, session_id
                                     FROM public.user_favorite_sessions
                                     WHERE user_id = %(userId)s) AS favorite_sessions