fix parallelity of worker processing