diff --git a/frontend_multi_user/src/app.py b/frontend_multi_user/src/app.py
index 7011f886..b00431fa 100644
--- a/frontend_multi_user/src/app.py
+++ b/frontend_multi_user/src/app.py
@@ -2920,6 +2920,7 @@ def run():
                 parameters = {}
             raw_profile = parameters.get("model_profile")
             parameters["model_profile"] = normalize_model_profile(raw_profile).value
+            parameters["pipeline_version"] = PIPELINE_VERSION
 
             # Get length of prompt_param in bytes and in characters
             prompt_param_bytes = len(prompt_param.encode('utf-8'))
@@ -3363,6 +3364,7 @@ def plan_retry():
             selected_model_profile = normalize_model_profile(raw_profile).value
             parameters = dict(task.parameters) if isinstance(task.parameters, dict) else {}
             parameters["model_profile"] = selected_model_profile
+            parameters["pipeline_version"] = PIPELINE_VERSION
             task.parameters = parameters
 
             task.state = PlanState.pending