changed naming of messaging methods

ChatWithDemonstrationsFlow.py

@@ -56,26 +56,41 @@ class ChatWithDemonstrationsFlow(CompositeFlow):
     def run(self,input_message):
         
         # #~~~~~~~~~~~Solution 1 - Blocking ~~~~~~~
-        # future = self.subflows["demonstration_flow"].send_message_blocking(input_message)
+        # future = self.subflows["demonstration_flow"].get_reply_future(input_message)
         
-        # answer = self.subflows["chat_flow"].send_message_blocking(future.get_message())
-        # self.reply_to_message(reply =self.output_interface(answer.get_message()), to=input_message)
+        # answer = self.subflows["chat_flow"].get_reply_future(future.get_message())
+        
+        #reply =  self.package_output_message(input_message, self.output_interface(answer.get_data()))
+        
+        # self.send_message(reply, is_reply=True)
         
         # #~~~~~~~~~~~Solution 2 - Non-Blocking ~~~~~~~
         if self.flow_state["last_flow_called"] is None:
             self.flow_state["input_message"] = input_message
-            self.subflows["demonstration_flow"].send_message_async(input_message,pipe_to=self.flow_config["flow_ref"])
+            self.subflows["demonstration_flow"].get_reply(
+                input_message,
+                self.get_instance_id(),
+            )
             self.flow_state["last_flow_called"] = "demonstration_flow"
         
         elif self.flow_state["last_flow_called"] == "demonstration_flow":
-            self.subflows["chat_flow"].send_message_async(input_message,pipe_to=self.flow_config["flow_ref"])
+            self.subflows["chat_flow"].get_reply(
+                input_message,
+                self.get_instance_id(),
+            )
             self.flow_state["last_flow_called"] = "chat_flow"
 
         else:
             self.flow_state["last_flow_called"] = None
-            self.reply_to_message(
-                reply =self.output_interface(input_message),
-                to=self.flow_state["input_message"]
+            
+            reply = self.package_output_message(
+                self.flow_state["input_message"],
+                response = self.output_interface(input_message).data
+            )
+                
+            self.send_message(
+                reply,
+                is_reply = True
             )
 
         

DemonstrationsAtomicFlow.py

@@ -191,8 +191,8 @@ class DemonstrationsAtomicFlow(AtomicFlow):
         :rtype: Dict[str, Any]
         """
         input_data = input_message.data
-        reply = self._package_output_message(
+        reply = self.package_output_message(
             input_message=input_message,
             response = {**{"demonstrations": self._get_io_pairs(input_data=input_data)},**input_data}
         )
-        self.reply_to_message(reply = reply, to=input_message)
+        self.send_message(reply, is_reply = True)

run.py

@@ -98,10 +98,10 @@ if __name__ == "__main__":
     )
 
     #option2: use the proxy_flow
-    #input_message = proxy_flow._package_input_message(data = data)
+    #input_message = proxy_flow.package_input_message(data = data)
     
     #7. ~~~ Run inference ~~~
-    future = proxy_flow.send_message_blocking(input_message)
+    future = proxy_flow.get_reply_future(input_message)
     
     #uncomment this line if you would like to get the full message back
     #reply_message = future.get_message()