Vincent Chéry
03/22/2021, 9:46 AMAmanda Wee
03/22/2021, 11:43 AMflow.run()
does not have checkpointing enabled by default, whereas it is enabled by default on prefect server (or cloud):
https://docs.prefect.io/core/concepts/results.html#pipeline-persisted-results
So this could mean that there's additional time needed to persist the prefect task results, from the list of 200 files to the results of subsequent tasks.Vincent Chéry
03/22/2021, 12:09 PMVincent Chéry
03/22/2021, 12:10 PMVincent Chéry
03/23/2021, 6:35 PM