Add package_input_message
Browse files- ChatHumanFlowModule.py +3 -1
- ChatHumanFlowModule.yaml +4 -2
- demo.yaml +2 -2
ChatHumanFlowModule.py
CHANGED
|
@@ -107,12 +107,13 @@ class ChatHumanFlowModule(CompositeFlow):
|
|
| 107 |
:type input_message: FlowMessage
|
| 108 |
"""
|
| 109 |
self.flow_state["assistant_outputs"].append(input_message.data["api_output"])
|
|
|
|
| 110 |
|
| 111 |
if self.max_rounds_reached():
|
| 112 |
self.generate_reply()
|
| 113 |
else:
|
| 114 |
self.subflows["User"].get_reply(
|
| 115 |
-
|
| 116 |
)
|
| 117 |
self.flow_state["last_state"] = "User"
|
| 118 |
|
|
@@ -127,6 +128,7 @@ class ChatHumanFlowModule(CompositeFlow):
|
|
| 127 |
:type input_message: FlowMessage
|
| 128 |
"""
|
| 129 |
message = self.input_interface_assistant(input_message)
|
|
|
|
| 130 |
|
| 131 |
if self.flow_state["last_state"] is None:
|
| 132 |
self.flow_state["input_message"] = input_message
|
|
|
|
| 107 |
:type input_message: FlowMessage
|
| 108 |
"""
|
| 109 |
self.flow_state["assistant_outputs"].append(input_message.data["api_output"])
|
| 110 |
+
message = self.package_input_message(data=input_message.data)
|
| 111 |
|
| 112 |
if self.max_rounds_reached():
|
| 113 |
self.generate_reply()
|
| 114 |
else:
|
| 115 |
self.subflows["User"].get_reply(
|
| 116 |
+
message,
|
| 117 |
)
|
| 118 |
self.flow_state["last_state"] = "User"
|
| 119 |
|
|
|
|
| 128 |
:type input_message: FlowMessage
|
| 129 |
"""
|
| 130 |
message = self.input_interface_assistant(input_message)
|
| 131 |
+
message = self.package_input_message(data=message.data)
|
| 132 |
|
| 133 |
if self.flow_state["last_state"] is None:
|
| 134 |
self.flow_state["input_message"] = input_message
|
ChatHumanFlowModule.yaml
CHANGED
|
@@ -25,12 +25,14 @@ end_of_interaction:
|
|
| 25 |
|
| 26 |
subflows_config:
|
| 27 |
Assistant:
|
| 28 |
-
|
|
|
|
| 29 |
flow_class_name: flow_modules.aiflows.ChatFlowModule.ChatAtomicFlow
|
| 30 |
flow_endpoint: Assistant
|
| 31 |
user_id: local
|
| 32 |
User:
|
| 33 |
-
|
|
|
|
| 34 |
flow_class_name: flow_modules.aiflows.HumanStandardInputFlowModule.HumanStandardInputFlow
|
| 35 |
flow_endpoint: User
|
| 36 |
user_id: local
|
|
|
|
| 25 |
|
| 26 |
subflows_config:
|
| 27 |
Assistant:
|
| 28 |
+
name: "Assistant"
|
| 29 |
+
description: "A flow that represents the assistant."
|
| 30 |
flow_class_name: flow_modules.aiflows.ChatFlowModule.ChatAtomicFlow
|
| 31 |
flow_endpoint: Assistant
|
| 32 |
user_id: local
|
| 33 |
User:
|
| 34 |
+
name: "User"
|
| 35 |
+
description: "A flow that represents the user."
|
| 36 |
flow_class_name: flow_modules.aiflows.HumanStandardInputFlowModule.HumanStandardInputFlow
|
| 37 |
flow_endpoint: User
|
| 38 |
user_id: local
|
demo.yaml
CHANGED
|
@@ -1,5 +1,5 @@
|
|
| 1 |
|
| 2 |
-
max_rounds:
|
| 3 |
_target_: flow_modules.aiflows.ChatInteractiveFlowModule.ChatHumanFlowModule.instantiate_from_default_config
|
| 4 |
subflows_config:
|
| 5 |
Assistant:
|
|
@@ -34,4 +34,4 @@ subflows_config:
|
|
| 34 |
input_interface:
|
| 35 |
- "api_output"
|
| 36 |
output_interface:
|
| 37 |
-
- "human_input"
|
|
|
|
| 1 |
|
| 2 |
+
max_rounds: 20
|
| 3 |
_target_: flow_modules.aiflows.ChatInteractiveFlowModule.ChatHumanFlowModule.instantiate_from_default_config
|
| 4 |
subflows_config:
|
| 5 |
Assistant:
|
|
|
|
| 34 |
input_interface:
|
| 35 |
- "api_output"
|
| 36 |
output_interface:
|
| 37 |
+
- "human_input"
|