add: inputs_reload参数，支持输入重载

Author: liq

api/controllers/console/app/completion.py

@@ -44,6 +44,7 @@ class CompletionMessageApi(Resource):
     def post(self, app_model):
         parser = reqparse.RequestParser()
         parser.add_argument("inputs", type=dict, required=True, location="json")
+        parser.add_argument("inputs_reload", type=bool, required=False, default=False, location="json")
         parser.add_argument("query", type=str, location="json", default="")
         parser.add_argument("files", type=list, required=False, location="json")
         parser.add_argument("model_config", type=dict, required=True, location="json")
@@ -105,6 +106,7 @@ class ChatMessageApi(Resource):
     def post(self, app_model):
         parser = reqparse.RequestParser()
         parser.add_argument("inputs", type=dict, required=True, location="json")
+        parser.add_argument("inputs_reload", type=bool, required=False, default=False, location="json")
         parser.add_argument("query", type=str, required=True, location="json")
         parser.add_argument("files", type=list, required=False, location="json")
         parser.add_argument("model_config", type=dict, required=True, location="json")

api/controllers/console/app/workflow.py

@@ -163,6 +163,7 @@ def post(self, app_model: App):
 
         parser = reqparse.RequestParser()
         parser.add_argument("inputs", type=dict, location="json")
+        parser.add_argument("inputs_reload", type=bool, required=False, default=False, location="json")
         parser.add_argument("query", type=str, required=True, location="json", default="")
         parser.add_argument("files", type=list, location="json")
         parser.add_argument("conversation_id", type=uuid_value, location="json")

api/controllers/console/explore/completion.py

@@ -37,6 +37,7 @@ def post(self, installed_app):
 
         parser = reqparse.RequestParser()
         parser.add_argument("inputs", type=dict, required=True, location="json")
+        parser.add_argument("inputs_reload", type=bool, required=False, default=False, location="json")
         parser.add_argument("query", type=str, location="json", default="")
         parser.add_argument("files", type=list, required=False, location="json")
         parser.add_argument("response_mode", type=str, choices=["blocking", "streaming"], location="json")
@@ -97,6 +98,7 @@ def post(self, installed_app):
 
         parser = reqparse.RequestParser()
         parser.add_argument("inputs", type=dict, required=True, location="json")
+        parser.add_argument("inputs_reload", type=bool, required=False, default=False, location="json")
         parser.add_argument("query", type=str, required=True, location="json")
         parser.add_argument("files", type=list, required=False, location="json")
         parser.add_argument("conversation_id", type=uuid_value, location="json")

api/controllers/service_api/app/completion.py

@@ -38,6 +38,7 @@ def post(self, app_model: App, end_user: EndUser):
 
         parser = reqparse.RequestParser()
         parser.add_argument("inputs", type=dict, required=True, location="json")
+        parser.add_argument("inputs_reload", type=bool, required=False, default=False, location="json")
         parser.add_argument("query", type=str, location="json", default="")
         parser.add_argument("files", type=list, required=False, location="json")
         parser.add_argument("response_mode", type=str, choices=["blocking", "streaming"], location="json")
@@ -101,6 +102,7 @@ def post(self, app_model: App, end_user: EndUser):
 
         parser = reqparse.RequestParser()
         parser.add_argument("inputs", type=dict, required=True, location="json")
+        parser.add_argument("inputs_reload", type=bool, required=False, default=False, location="json")
         parser.add_argument("query", type=str, required=True, location="json")
         parser.add_argument("files", type=list, required=False, location="json")
         parser.add_argument("response_mode", type=str, choices=["blocking", "streaming"], location="json")

api/controllers/web/completion.py

@@ -36,6 +36,7 @@ def post(self, app_model, end_user):
 
         parser = reqparse.RequestParser()
         parser.add_argument("inputs", type=dict, required=True, location="json")
+        parser.add_argument("inputs_reload", type=bool, required=False, default=False, location="json")
         parser.add_argument("query", type=str, location="json", default="")
         parser.add_argument("files", type=list, required=False, location="json")
         parser.add_argument("response_mode", type=str, choices=["blocking", "streaming"], location="json")
@@ -92,6 +93,7 @@ def post(self, app_model, end_user):
 
         parser = reqparse.RequestParser()
         parser.add_argument("inputs", type=dict, required=True, location="json")
+        parser.add_argument("inputs_reload", type=bool, required=False, default=False, location="json")
         parser.add_argument("query", type=str, required=True, location="json")
         parser.add_argument("files", type=list, required=False, location="json")
         parser.add_argument("response_mode", type=str, choices=["blocking", "streaming"], location="json")

api/core/app/apps/advanced_chat/app_generator.py

@@ -66,6 +66,7 @@ def generate(
 
         query = query.replace('\x00', '')
         inputs = args['inputs']
+        inputs_reload = args["inputs_reload"]
 
         extras = {
             "auto_generate_conversation_name": args.get('auto_generate_name', False)
@@ -109,7 +110,7 @@ def generate(
             task_id=str(uuid.uuid4()),
             app_config=app_config,
             conversation_id=conversation.id if conversation else None,
-            inputs=conversation.inputs if conversation else self._get_cleaned_inputs(inputs, app_config),
+            inputs=conversation.inputs if conversation and not inputs_reload else self._get_cleaned_inputs(inputs, app_config),
             query=query,
             files=file_objs,
             user_id=user.id,

api/core/app/apps/agent_chat/app_generator.py

@@ -55,6 +55,7 @@ def generate(self, app_model: App,
 
         query = query.replace('\x00', '')
         inputs = args['inputs']
+        inputs_reload = args["inputs_reload"]
 
         extras = {
             "auto_generate_conversation_name": args.get('auto_generate_name', True)
@@ -119,7 +120,7 @@ def generate(self, app_model: App,
             app_config=app_config,
             model_conf=ModelConfigConverter.convert(app_config),
             conversation_id=conversation.id if conversation else None,
-            inputs=conversation.inputs if conversation else self._get_cleaned_inputs(inputs, app_config),
+            inputs=conversation.inputs if conversation and not inputs_reload else self._get_cleaned_inputs(inputs, app_config),
             query=query,
             files=file_objs,
             user_id=user.id,

api/core/app/apps/chat/app_generator.py

@@ -53,6 +53,7 @@ def generate(
 
         query = query.replace('\x00', '')
         inputs = args['inputs']
+        inputs_reload = args["inputs_reload"]
 
         extras = {
             "auto_generate_conversation_name": args.get('auto_generate_name', True)
@@ -116,7 +117,7 @@ def generate(
             app_config=app_config,
             model_conf=ModelConfigConverter.convert(app_config),
             conversation_id=conversation.id if conversation else None,
-            inputs=conversation.inputs if conversation else self._get_cleaned_inputs(inputs, app_config),
+            inputs=conversation.inputs if conversation and not inputs_reload else self._get_cleaned_inputs(inputs, app_config),
             query=query,
             files=file_objs,
             user_id=user.id,

web/app/components/develop/template/template_advanced_chat.zh.mdx

@@ -47,6 +47,9 @@ import { Row, Col, Properties, Property, Heading, SubProperty } from '../md.tsx'
         允许传入 App 定义的各变量值。
         inputs 参数包含了多组键值对（Key/Value pairs），每组的键对应一个特定变量，每组的值则是该变量的具体值。
         默认 `{}`
+      </Property>
+	  <Property name='inputs_reload' type='bool' key='inputs_reload'>
+        `定制化变量`  是否重载输入变量,默认 `false`
       </Property>
       <Property name='response_mode' type='string' key='response_mode'>
         - `streaming` 流式模式（推荐）。基于 SSE（**[Server-Sent Events](https://developer.mozilla.org/en-US/docs/Web/API/Server-sent_events/Using_server-sent_events)**）实现类似打字机输出方式的流式返回。

web/app/components/develop/template/template_chat.zh.mdx

@@ -47,6 +47,9 @@ import { Row, Col, Properties, Property, Heading, SubProperty } from '../md.tsx'
         允许传入 App 定义的各变量值。
         inputs 参数包含了多组键值对（Key/Value pairs），每组的键对应一个特定变量，每组的值则是该变量的具体值。
         默认 `{}`
+      </Property>
+	  <Property name='inputs_reload' type='bool' key='inputs_reload'>
+        `定制化变量`  是否重载输入变量,默认 `false`
       </Property>
       <Property name='response_mode' type='string' key='response_mode'>
         - `streaming` 流式模式（推荐）。基于 SSE（**[Server-Sent Events](https://developer.mozilla.org/en-US/docs/Web/API/Server-sent_events/Using_server-sent_events)**）实现类似打字机输出方式的流式返回。