peichao.dong commited on
Commit
820ecd2
·
1 Parent(s): d237496

test graph draw

Browse files
Files changed (2) hide show
  1. backend/business.py +39 -39
  2. backend/essay_writer.py +25 -25
backend/business.py CHANGED
@@ -227,49 +227,49 @@ def human_feedback(
227
  return history, acs
228
 
229
 
230
- # if __name__ == "__main__":
231
- # from IPython.display import Image,display
232
- # abot = Agent(
233
- # model=ChatOpenAI(model="gpt-4o", streaming=True),
234
- # checkpointer=SqliteSaver.from_conn_string(":memory:"),
235
- # )
236
- # png_data = abot.graph.get_graph().draw_mermaid_png()
237
- # with open('backend/business.png', 'wb') as file:
238
- # file.write(png_data)
239
-
240
- # thread = {"configurable": {"thread_id": "1"}}
241
-
242
- # # print(abot.graph.get_state(thread))
243
- # context = """Feature Config指的是一些特性的配置信息,例如应用程序的功能模块和设置。
244
-
245
- # 管理员可以通过界面进行新增、修改、分页查看、发布、撤销和删除操作;
246
-
247
- # 新增Feature Config应该提供 FeatureKey(通过FeatureKey 与Feature关联),title 和 description, data(配置的数据,数据格式依据Feature配置模版生成,由用户填写),saData(键值对埋点数据,由用户自定义输入),圈人条件(包括开始时间、截止时间、圈人白名单、地理位置、灰度比例等)
248
-
249
- # 新增后FeatureConfig记录状态默认为DRFAT。 管理课对DRAFT状态的数据执行发布操作,发布后记录变为PUBLISHED状态, 仅PUBLISHED状态的数据且符合圈人条件的配置C端可见。PUBLISHED状态的数据可执行撤销操作,撤销后记录变为DISABLED状态。
250
-
251
- # 对DRAFT状态的记录执行删除操作后,记录会从数据库中物理删除,非DRAFT状态的记录,执行删除操作,进行逻辑删除状态标记为DELETED,DELETED状态的数据在管理界面上不可见。"""
252
- # story = """作为系统管理员
253
- # 我希望系统提供Feature Config新增/修改/分页查看/发布/撤销/删除的能力
254
- # 以便我增加/修改Feature中对应的配置信息"""
255
- # for event in abot.graph.stream({"context": context.format(),
256
- # "story": story.format(),
257
- # "max_revisions": 10,
258
- # "revision_number": 1}, thread, stream_mode="values"):
259
- # print(event)
260
 
261
 
262
- # print(abot.graph.get_state(thread).values)
263
 
264
- # for event in abot.graph.stream(None, thread, stream_mode="values"):
265
- # print(event)
266
 
267
- # print(abot.graph.get_state(thread).values)
268
 
269
- # for event in abot.graph.stream(None, thread, stream_mode="values"):
270
- # print(event)
271
 
272
- # print(abot.graph.get_state(thread).values)
273
 
274
- # # print(r, end= "\n\n")
275
- # # print(r["question"], end="\n\n")
 
227
  return history, acs
228
 
229
 
230
+ if __name__ == "__main__":
231
+ from IPython.display import Image,display
232
+ abot = Agent(
233
+ model=ChatOpenAI(model="gpt-4o", streaming=True),
234
+ checkpointer=SqliteSaver.from_conn_string(":memory:"),
235
+ )
236
+ png_data = abot.graph.get_graph().draw_mermaid_png()
237
+ with open('backend/business.png', 'wb') as file:
238
+ file.write(png_data)
239
+
240
+ thread = {"configurable": {"thread_id": "1"}}
241
+
242
+ # print(abot.graph.get_state(thread))
243
+ context = """Feature Config指的是一些特性的配置信息,例如应用程序的功能模块和设置。
244
+
245
+ 管理员可以通过界面进行新增、修改、分页查看、发布、撤销和删除操作;
246
+
247
+ 新增Feature Config应该提供 FeatureKey(通过FeatureKey 与Feature关联),title 和 description, data(配置的数据,数据格式依据Feature配置模版生成,由用户填写),saData(键值对埋点数据,由用户自定义输入),圈人条件(包括开始时间、截止时间、圈人白名单、地理位置、灰度比例等)
248
+
249
+ 新增后FeatureConfig记录状态默认为DRFAT。 管理课对DRAFT状态的数据执行发布操作,发布后记录变为PUBLISHED状态, 仅PUBLISHED状态的数据且符合圈人条件的配置C端可见。PUBLISHED状态的数据可执行撤销操作,撤销后记录变为DISABLED状态。
250
+
251
+ 对DRAFT状态的记录执行删除操作后,记录会从数据库中物理删除,非DRAFT状态的记录,执行删除操作,进行逻辑删除状态标记为DELETED,DELETED状态的数据在管理界面上不可见。"""
252
+ story = """作为系统管理员
253
+ 我希望系统提供Feature Config新增/修改/分页查看/发布/撤销/删除的能力
254
+ 以便我增加/修改Feature中对应的配置信息"""
255
+ for event in abot.graph.stream({"context": context.format(),
256
+ "story": story.format(),
257
+ "max_revisions": 10,
258
+ "revision_number": 1}, thread, stream_mode="values"):
259
+ print(event)
260
 
261
 
262
+ print(abot.graph.get_state(thread).values)
263
 
264
+ for event in abot.graph.stream(None, thread, stream_mode="values"):
265
+ print(event)
266
 
267
+ print(abot.graph.get_state(thread).values)
268
 
269
+ for event in abot.graph.stream(None, thread, stream_mode="values"):
270
+ print(event)
271
 
272
+ print(abot.graph.get_state(thread).values)
273
 
274
+ # print(r, end= "\n\n")
275
+ # print(r["question"], end="\n\n")
backend/essay_writer.py CHANGED
@@ -189,29 +189,29 @@ def essay_writer_respond(
189
 
190
 
191
 
192
- # if __name__ == "__main__":
193
- # from IPython.display import Image,display
194
- # abot = Agent(
195
- # model=ChatOpenAI(model="gpt-4o-mini", streaming=True),
196
- # checkpointer=SqliteSaver.from_conn_string(":memory:"),
197
- # )
198
- # png_data = abot.graph.get_graph().draw_mermaid_png()
199
- # display(Image(abot.graph.get_graph().draw_mermaid_png()))
200
- # with open('backend/essay_writer.png', 'wb') as file:
201
- # file.write(png_data)
202
-
203
- # thread = {"configurable": {"thread_id": "1"}}
204
-
205
- # print(abot.graph.get_state(thread))
206
-
207
- # r = abot.graph.invoke(
208
- # {"task": "Write an essay on the importance of education",
209
- # "max_revisions": 2,
210
- # "revision_number": 1,},
211
- # thread,
212
- # )
213
-
214
- # print(abot.graph.get_state(thread).values['draft'])
215
 
216
- # print(r, end= "\n\n")
217
- # print(r["draft"], end="\n\n")
 
189
 
190
 
191
 
192
+ if __name__ == "__main__":
193
+ from IPython.display import Image,display
194
+ abot = Agent(
195
+ model=ChatOpenAI(model="gpt-4o-mini", streaming=True),
196
+ checkpointer=SqliteSaver.from_conn_string(":memory:"),
197
+ )
198
+ png_data = abot.graph.get_graph().draw_mermaid_png()
199
+ display(Image(abot.graph.get_graph().draw_mermaid_png()))
200
+ with open('backend/essay_writer.png', 'wb') as file:
201
+ file.write(png_data)
202
+
203
+ thread = {"configurable": {"thread_id": "1"}}
204
+
205
+ print(abot.graph.get_state(thread))
206
+
207
+ r = abot.graph.invoke(
208
+ {"task": "Write an essay on the importance of education",
209
+ "max_revisions": 2,
210
+ "revision_number": 1,},
211
+ thread,
212
+ )
213
+
214
+ print(abot.graph.get_state(thread).values['draft'])
215
 
216
+ print(r, end= "\n\n")
217
+ print(r["draft"], end="\n\n")