Using Python streamz and dask, I want to distribute the data of textfiles that are generated to threads