remove is_reply
Browse files
ChatWithDemonstrationsFlow.py
CHANGED
@@ -62,7 +62,7 @@ class ChatWithDemonstrationsFlow(CompositeFlow):
|
|
62 |
|
63 |
#reply = self.package_output_message(input_message, self.output_interface(answer.get_data()))
|
64 |
|
65 |
-
# self.send_message(reply
|
66 |
|
67 |
# #~~~~~~~~~~~Solution 2 - Non-Blocking ~~~~~~~
|
68 |
if self.flow_state["last_flow_called"] is None:
|
@@ -89,8 +89,7 @@ class ChatWithDemonstrationsFlow(CompositeFlow):
|
|
89 |
)
|
90 |
|
91 |
self.send_message(
|
92 |
-
reply
|
93 |
-
is_reply = True
|
94 |
)
|
95 |
|
96 |
|
|
|
62 |
|
63 |
#reply = self.package_output_message(input_message, self.output_interface(answer.get_data()))
|
64 |
|
65 |
+
# self.send_message(reply)
|
66 |
|
67 |
# #~~~~~~~~~~~Solution 2 - Non-Blocking ~~~~~~~
|
68 |
if self.flow_state["last_flow_called"] is None:
|
|
|
89 |
)
|
90 |
|
91 |
self.send_message(
|
92 |
+
reply
|
|
|
93 |
)
|
94 |
|
95 |
|
DemonstrationsAtomicFlow.py
CHANGED
@@ -195,4 +195,4 @@ class DemonstrationsAtomicFlow(AtomicFlow):
|
|
195 |
input_message=input_message,
|
196 |
response = {**{"demonstrations": self._get_io_pairs(input_data=input_data)},**input_data}
|
197 |
)
|
198 |
-
self.send_message(reply
|
|
|
195 |
input_message=input_message,
|
196 |
response = {**{"demonstrations": self._get_io_pairs(input_data=input_data)},**input_data}
|
197 |
)
|
198 |
+
self.send_message(reply)
|