diff --git a/api/core/app/apps/pipeline/pipeline_generator.py b/api/core/app/apps/pipeline/pipeline_generator.py
index 30cf676c11..99c261bd89 100644
--- a/api/core/app/apps/pipeline/pipeline_generator.py
+++ b/api/core/app/apps/pipeline/pipeline_generator.py
@@ -314,6 +314,7 @@ class PipelineGenerator(BaseAppGenerator):
 
             draft_var_saver_factory = self._get_draft_var_saver_factory(
                 invoke_from,
+                user,
             )
             # return response or stream generator
             response = self._handle_response(