diff --git a/api/chalicelib/core/assist.py b/api/chalicelib/core/assist.py
index 70f563ec8..44adfe2d1 100644
--- a/api/chalicelib/core/assist.py
+++ b/api/chalicelib/core/assist.py
@@ -64,9 +64,10 @@ def get_live_sessions(project_id, filters=None):
     return helper.list_to_camel_case(results)
 
 
-def get_live_sessions_ws(project_id):
+def get_live_sessions_ws(project_id, user_id=None):
     project_key = projects.get_project_key(project_id)
-    connected_peers = requests.get(config("peers") % config("S3_KEY") + f"/{project_key}")
+    connected_peers = requests.get(config("peers") % config("S3_KEY") \
+                                   + f"/{project_key}" + (f"?userId={user_id}" if user_id else ""))
     if connected_peers.status_code != 200:
         print("!! issue with the peer-server")
         print(connected_peers.text)
diff --git a/api/routers/core.py b/api/routers/core.py
index df9ce0e8f..97a749429 100644
--- a/api/routers/core.py
+++ b/api/routers/core.py
@@ -820,15 +820,8 @@ def all_issue_types(context: schemas.CurrentContext = Depends(OR_context)):
 
 
 @app.get('/{projectId}/assist/sessions', tags=["assist"])
-def sessions_live(projectId: int, context: schemas.CurrentContext = Depends(OR_context)):
-    data = assist.get_live_sessions_ws(projectId)
-    return {'data': data}
-
-
-@app.post('/{projectId}/assist/sessions', tags=["assist"])
-def sessions_live_search(projectId: int, data: schemas.AssistSearchPayloadSchema = Body(...),
-                         context: schemas.CurrentContext = Depends(OR_context)):
-    data = assist.get_live_sessions_ws(projectId)
+def sessions_live(projectId: int, userId: str = None, context: schemas.CurrentContext = Depends(OR_context)):
+    data = assist.get_live_sessions_ws(projectId, user_id=userId)
     return {'data': data}