prefect api 实现

`prefect`是一个Python库，用于构建、部署和管理工作流，它提供了一个叫做`API`的核心组件，使得用户可以方便地通过程序的方式来创建、运行和管理任务流程。`prefect.api`模块包含了一系列的函数和类，如`Flow` API用于创建工作流，`Task` API用于创建任务，`Client` API允许远程操作和监控工作流等。

使用`prefect` API，你可以做如下操作：

1. **创建任务**：定义一个自定义任务，指定输入、输出以及任务执行的逻辑。

from prefect import task

@task
def add(a, b):
    return a + b

2. **创建工作流**：将任务组合成工作流，并设置任务之间的依赖关系。

from prefect import Flow

with Flow("Addition Workflow") as flow:
    result = add(task1.result, task2.result)

3. **调度和运行**：通过`Client` API启动工作流，可以选择立即运行或定时调度。

from prefect.client import Client

client = Client()
client.create_flow_run(flow=flow)

4. **监控状态**：查看工作流的状态、结果和日志。

run = client.get_run(flow_id)
print(run.status)