Apply an async method to a Dask DataFrame I have an async method that I want to run on every row in all partitions of a Dask dataframe: