importAgently
# 创建工作流对象
workflow = Agently.Workflow()
# 定义工作块
@workflow.chunk()
defuser_input(inputs, storage):
# 参数inputs承接上游直接传递的数据
# 参数storage管理单个工作流内共享的数据
storage.set("init_inputs", inputs["default"])
new_msg = input("[输入新的信息]: ")
return new_msg
@workflow.chunk()
defecho(inputs, storage):
print("[您刚才输入的是]: ", inputs["default"])
return {
"user_input": inputs["default"],
"init_inputs": storage.get("init_inputs"),
"init_storage": storage.get("init_storage")
}
# 定义工作流运行关系
(
workflow
.connect_to("user_input")
.connect_to("echo")
.connect_to("END") # 连接到系统内置的end块
)
# 启动工作流并获取运行结果
result = workflow.start(
# 默认参数的值可传递给第一步连接块的inputs
"Hello Agently",
# 可选参数storage可设置storage的初始值
storage={ "init_storage": "Hello Agently Workflow" }
)
print(result) # 工作流运行结果是连接到END块的数据