Used Map functionality, But at a given point of time, I only see hike in only one cpi. Used DaskExecutor with 8 worker and 4 thread.Can anyone tell what is the issue.
k
Kevin Kho
04/04/2022, 1:34 PM
Could you show me how you set the executor? Did you set it in a different file than the flow?
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.