changed commit methods

HumanStandardInputFlow.py

@@ -162,6 +162,9 @@ class HumanStandardInputFlow(AtomicFlow):
         log.info(query_message)
         human_input = self._read_input()
 
-        reply_message = self._package_output_message(input_message = input_message, response = {"human_input": human_input})
+        reply_message = self.package_output_message(
+            input_message = input_message,
+            response = {"human_input": human_input}
+        )
         
-        self.reply_to_message(reply = reply_message, to = input_message)
+        self.send_message(reply_message, is_reply = True)

run.py

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