Skip to content
Snippets Groups Projects
Unverified Commit f5dd1ba3 authored by Jinchao Li's avatar Jinchao Li Committed by GitHub
Browse files

Human2 (#137)

* change task config

* add final goal logging

* encapsule PipelineAgent internal state interface for return and
replacement

* fix bug associted with the issue of strange user input
parent 41da08d4
No related branches found
No related tags found
No related merge requests found
...@@ -35,16 +35,18 @@ agent = PipelineAgent(sys_nlu,sys_dst,sys_policy, sys_nlg,'sys') ...@@ -35,16 +35,18 @@ agent = PipelineAgent(sys_nlu,sys_dst,sys_policy, sys_nlg,'sys')
print(agent.response('I am looking for a hotel')) print(agent.response('I am looking for a hotel'))
global_counter = 0
@app.route('/', methods=['GET', 'POST']) @app.route('/', methods=['GET', 'POST'])
def process(): def process():
global global_counter
try: try:
in_request = request.json in_request = request.json
print(in_request) print(in_request)
except: except:
return "invalid input: {}".format(in_request) return "invalid input: {}".format(in_request)
rgi_queue.put(in_request) global_counter += 1
rgi_queue.join() rgi_queue.put((global_counter, in_request))
# rgi_queue.join()
output = rgo_queue.get() output = rgo_queue.get()
print(output['response']) print(output['response'])
rgo_queue.task_done() rgo_queue.task_done()
...@@ -56,7 +58,7 @@ def generate_response(in_queue, out_queue): ...@@ -56,7 +58,7 @@ def generate_response(in_queue, out_queue):
while True: while True:
# pop input # pop input
# last_action = 'null' # last_action = 'null'
in_request = in_queue.get() _, in_request = in_queue.get()
obs = in_request['input'] obs = in_request['input']
if in_request['agent_state'] == {}: if in_request['agent_state'] == {}:
agent.init_session() agent.init_session()
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment