我在 Prefect 中有一个流程,其中 DB 客户端的启动和停止针对每个映射任务进行。下面是示例 ETL 结束的视觉效果。
save_transformed_data_to_db
接受一个,unmapped(database)
和unmapped(db_client)
一个映射data
值。
有没有办法将任务设置为在整个流程开始时只运行一次,在整个流程结束时只运行一次,如果是 - 如何?
我在 Prefect 中有一个流程,其中 DB 客户端的启动和停止针对每个映射任务进行。下面是示例 ETL 结束的视觉效果。
save_transformed_data_to_db
接受一个,unmapped(database)
和unmapped(db_client)
一个映射data
值。
有没有办法将任务设置为在整个流程开始时只运行一次,在整个流程结束时只运行一次,如果是 - 如何?