changed naming of messaging methods

ChatHumanFlowModule.py

@@ -82,7 +82,7 @@ class ChatHumanFlowModule(CompositeFlow):
     
     def generate_reply(self):
         
-        reply = self._package_output_message(
+        reply = self.package_output_message(
             input_message = self.flow_state["input_message"],
             response = {
                 "user_inputs": self.flow_state["user_inputs"],
@@ -91,9 +91,9 @@ class ChatHumanFlowModule(CompositeFlow):
             },
         )
         
-        self.reply_to_message(
-            reply = reply,
-            to = self.flow_state["input_message"]
+        self.send_message(
+            reply,
+            is_reply = True
         )
         
             
@@ -105,7 +105,10 @@ class ChatHumanFlowModule(CompositeFlow):
         if self.max_rounds_reached():
             self.generate_reply()
         else:
-            self.subflows["User"].send_message_async(input_message,pipe_to=self.flow_config["flow_ref"])
+            self.subflows["User"].get_reply(
+                input_message,
+                self.get_instance_id(),
+            )
             self.flow_state["last_flow_called"] = "User"
         
         self.flow_state["current_round"] += 1
@@ -126,7 +129,10 @@ class ChatHumanFlowModule(CompositeFlow):
             self.generate_reply()
             
         else:
-            self.subflows["Assistant"].send_message_async(message,pipe_to=self.flow_config["flow_ref"])
+            self.subflows["Assistant"].get_reply(
+                message,
+                self.get_instance_id()
+            )
             self.flow_state["last_flow_called"] = "Assistant"    
     
     def run(self,input_message: FlowMessage):

run.py

@@ -88,10 +88,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()