zns0327 commited on
Commit
601bc4d
·
1 Parent(s): a82b969

log user identification code as well

Browse files
Files changed (1) hide show
  1. app.py +18 -13
app.py CHANGED
@@ -11,14 +11,16 @@ class SessionManager:
11
  def add_session(self, cooperate_style, task):
12
  if cooperate_style == "sequential":
13
  session = {
 
14
  "task": task,
15
- "human_initial_answer": None,
16
  "cooperate_style": cooperate_style,
 
17
  "ai_modificated_output": None,
18
  "evaluation": None
19
  }
20
  elif cooperate_style == "reverse_sequential":
21
  session = {
 
22
  "task": task,
23
  "cooperate_style": cooperate_style,
24
  "ai_initial_answer": None,
@@ -27,7 +29,8 @@ class SessionManager:
27
  "evaluation": None
28
  }
29
  elif cooperate_style == "parallel":
30
- session = {
 
31
  "task": task,
32
  "cooperate_style": cooperate_style,
33
  "ai_initial_answer": None,
@@ -51,16 +54,17 @@ class SessionManager:
51
 
52
 
53
 
54
- def handle_create_sequential(task, human_input, session_manager, api_key):
55
  cooperate_style = "sequential"
56
  session_index = session_manager.add_session(task=task, cooperate_style=cooperate_style)
57
  session_manager.update(session_index, human_input, 'human_initial_answer')
58
  output = merge_texts_sequential(task, human_input, api_key)
59
  session_manager.update(session_index, output, 'ai_modificated_output')
 
60
  return output, session_index
61
 
62
 
63
- def handle_create_parallel(task, human_input, session_manager, api_key):
64
  cooperate_style = "parallel"
65
  session_index = session_manager.add_session(task=task, cooperate_style=cooperate_style)
66
  ai_initial_answer = generate_ai_initial_answer(task, api_key)
@@ -68,13 +72,15 @@ def handle_create_parallel(task, human_input, session_manager, api_key):
68
  session_manager.update(session_index, ai_initial_answer, 'ai_initial_answer')
69
  final_answer = merge_texts_parallel(task, human_input, ai_initial_answer, api_key)
70
  session_manager.update(session_index, final_answer, 'merged_final_answer')
 
71
  return ai_initial_answer, final_answer, session_index
72
 
73
- def handle_create_reverse_sequential(task, session_manager, api_key):
74
  cooperate_style = "reverse_sequential"
75
  session_index = session_manager.add_session(task=task, cooperate_style=cooperate_style)
76
  ai_initial_answer = generate_ai_initial_answer(task, api_key)
77
  session_manager.update(session_index, ai_initial_answer, 'ai_initial_answer')
 
78
  return ai_initial_answer, session_index
79
 
80
 
@@ -114,8 +120,7 @@ if __name__ == "__main__":
114
  api_key = get_api_key(local=False)
115
  service, SHEET_IDs = get_sheet_service(local=False)
116
  SHEET_ID1, SHEET_ID2, SHEET_ID3 = SHEET_IDs
117
- # print(api_key)
118
- # print(SHEET_ID1, SHEET_ID2, SHEET_ID3)
119
  session_manager = SessionManager()
120
 
121
  with gr.Blocks() as app:
@@ -157,8 +162,8 @@ if __name__ == "__main__":
157
  session_index = gr.Number(label="Session Index", visible=False)
158
 
159
  submit_btn.click(
160
- fn=lambda task, human_input: handle_create_sequential(task, human_input, session_manager, api_key),
161
- inputs=[task, human_input],
162
  outputs=[ai_output, session_index]
163
  )
164
 
@@ -193,8 +198,8 @@ if __name__ == "__main__":
193
  session_index = gr.Number(label="Session Index", visible=False)
194
 
195
  create_btn.click(
196
- fn=lambda task, human_input: handle_create_parallel(task, human_input, session_manager, api_key),
197
- inputs=[task, human_input],
198
  outputs=[ai_initial_output, final_output, session_index]
199
  )
200
 
@@ -235,8 +240,8 @@ if __name__ == "__main__":
235
 
236
 
237
  create_initial_btn.click(
238
- fn=lambda task: handle_create_reverse_sequential(task, session_manager, api_key),
239
- inputs=[task],
240
  outputs=[initial_answer, session_index]
241
  )
242
 
 
11
  def add_session(self, cooperate_style, task):
12
  if cooperate_style == "sequential":
13
  session = {
14
+ "user_identification_code": None,
15
  "task": task,
 
16
  "cooperate_style": cooperate_style,
17
+ "human_initial_answer": None,
18
  "ai_modificated_output": None,
19
  "evaluation": None
20
  }
21
  elif cooperate_style == "reverse_sequential":
22
  session = {
23
+ "user_identification_code": None,
24
  "task": task,
25
  "cooperate_style": cooperate_style,
26
  "ai_initial_answer": None,
 
29
  "evaluation": None
30
  }
31
  elif cooperate_style == "parallel":
32
+ session = {
33
+ "user_identification_code": None,
34
  "task": task,
35
  "cooperate_style": cooperate_style,
36
  "ai_initial_answer": None,
 
54
 
55
 
56
 
57
+ def handle_create_sequential(task, human_input, session_manager, api_key, identification_code):
58
  cooperate_style = "sequential"
59
  session_index = session_manager.add_session(task=task, cooperate_style=cooperate_style)
60
  session_manager.update(session_index, human_input, 'human_initial_answer')
61
  output = merge_texts_sequential(task, human_input, api_key)
62
  session_manager.update(session_index, output, 'ai_modificated_output')
63
+ session_manager.update(session_index, identification_code, 'user_identification_code')
64
  return output, session_index
65
 
66
 
67
+ def handle_create_parallel(task, human_input, session_manager, api_key, identification_code):
68
  cooperate_style = "parallel"
69
  session_index = session_manager.add_session(task=task, cooperate_style=cooperate_style)
70
  ai_initial_answer = generate_ai_initial_answer(task, api_key)
 
72
  session_manager.update(session_index, ai_initial_answer, 'ai_initial_answer')
73
  final_answer = merge_texts_parallel(task, human_input, ai_initial_answer, api_key)
74
  session_manager.update(session_index, final_answer, 'merged_final_answer')
75
+ session_manager.update(session_index, identification_code, 'user_identification_code')
76
  return ai_initial_answer, final_answer, session_index
77
 
78
+ def handle_create_reverse_sequential(task, session_manager, api_key, identification_code):
79
  cooperate_style = "reverse_sequential"
80
  session_index = session_manager.add_session(task=task, cooperate_style=cooperate_style)
81
  ai_initial_answer = generate_ai_initial_answer(task, api_key)
82
  session_manager.update(session_index, ai_initial_answer, 'ai_initial_answer')
83
+ session_manager.update(session_index, identification_code, 'user_identification_code')
84
  return ai_initial_answer, session_index
85
 
86
 
 
120
  api_key = get_api_key(local=False)
121
  service, SHEET_IDs = get_sheet_service(local=False)
122
  SHEET_ID1, SHEET_ID2, SHEET_ID3 = SHEET_IDs
123
+
 
124
  session_manager = SessionManager()
125
 
126
  with gr.Blocks() as app:
 
162
  session_index = gr.Number(label="Session Index", visible=False)
163
 
164
  submit_btn.click(
165
+ fn=lambda task, human_input, id: handle_create_sequential(task, human_input, session_manager, api_key, id),
166
+ inputs=[task, human_input, identification_code],
167
  outputs=[ai_output, session_index]
168
  )
169
 
 
198
  session_index = gr.Number(label="Session Index", visible=False)
199
 
200
  create_btn.click(
201
+ fn=lambda task, human_input, id: handle_create_parallel(task, human_input, session_manager, api_key),
202
+ inputs=[task, human_input, identification_code],
203
  outputs=[ai_initial_output, final_output, session_index]
204
  )
205
 
 
240
 
241
 
242
  create_initial_btn.click(
243
+ fn=lambda task, id: handle_create_reverse_sequential(task, session_manager, api_key, id),
244
+ inputs=[task, identification_code],
245
  outputs=[initial_answer, session_index]
246
  )
247