changed naming of messaging methods

AutoGPTFlow.py

@@ -174,39 +174,39 @@ class AutoGPTFlow(ControllerExecutorFlow):
     def call_memory_read(self):
         memory_read_input = self.prepare_memory_read_input()
         
-        message = self._package_input_message(
+        message = self.package_input_message(
             data = memory_read_input,
             dst_flow = "Memory",
         )
         
-        self.subflows["Memory"].send_message_async(
+        self.subflows["Memory"].get_reply(
             message,
-            pipe_to = self.flow_config["flow_ref"]
+            self.get_instance_id(),
         )
 
     def call_memory_write(self):
         memory_write_input = self.prepare_memory_write_input()
         
-        message = self._package_input_message(
+        message = self.package_input_message(
             data = memory_write_input,
             dst_flow = "Memory",
         )
         
-        self.subflows["Memory"].send_message_async(
+        self.subflows["Memory"].get_reply(
             message,
-            pipe_to = self.flow_config["flow_ref"]
+            self.get_instance_id(),
         )
     
     def call_human_feedback(self):
             
-        message = self._package_input_message(
+        message = self.package_input_message(
             data = self.input_interface_human_feedback(self.flow_state),
             dst_flow = "HumanFeedback",
         )
         
-        self.subflows["HumanFeedback"].send_message_async(
+        self.subflows["HumanFeedback"].get_reply(
             message,
-            pipe_to = self.flow_config["flow_ref"]
+            self.get_instance_id(),
         )
              
     def register_data_to_state(self, input_message):
@@ -269,10 +269,6 @@ class AutoGPTFlow(ControllerExecutorFlow):
                 
                 self.flow_state["early_exit_flag"] = True
         
-        
-            
-        
-    
     def run(self,input_message):
         
         self.register_data_to_state(input_message)

run.py

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