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.

Could you show me how you set the executor? Did you set it in a different file than the flow?