prefect flow 关联task

在 Prefect (前身为 Prefect Core) 这个任务驱动的操作流管理框架中，`Flow` 和 `Task` 的关联是非常核心的概念。`Flow` 可以看作是一个容器，它包含了多个可以并行或串行执行的 `Task`。以下是关联 `Task` 到 `Flow` 的几个关键步骤：

1. **定义 Task**：首先，你需要定义一个或多个 `Task` 对象，这些任务可以是内置的 Prefect 类，也可以是你自定义的任务。每个任务代表一个单独的工作单元，并且通常有一个输入和一个输出。

   from prefect import task
   @task
   def add_numbers(a, b):
       return a + b

2. **添加 Task 到 Flow**：`Flow` 通过 `add_task` 或 `run_tasks_in_series` 等方法将任务添加到流程中。你可以选择将它们串联（顺序执行），或者并行执行。比如：

   with prefect.Flow("Add Numbers") as flow:
       result_1 = add_numbers(1, 2)
       result_2 = add_numbers(3, 4)
       # 串行执行
       result_sum = result_1 + result_2

3. **运行 Flow**：一旦你的 `Flow` 配置完成，就可以使用 `.run()` 方法启动流程并执行所有关联的任务。这将触发每个任务的执行，并自动处理依赖关系。

   flow.run()