Hello :) I'm wondering if someone can explain to me how does prefect core execute mapping with the DaskExecuter. In the Docs, it's said that Prefect automatically creates a copy of the task for each element of its input data. However, looking at the code I'm not understanding where that is being done, and when those new tasks are being submitted to Dask.
d
Dylan
08/20/2020, 9:39 PM
Hey @Ruben Silva!
This is probably a good question for #C0106HZ1CMS as we’re getting pretty deep into the internals
Bring your towel and join one of the fastest growing data communities. Welcome to our second-generation open source orchestration platform, a completely rethought approach to dataflow automation.