How can I use with dask.delayed functions?

[kszucs]

Could You provide an example to map functions returning Delayed objects?

[mrocklin]

I am unlikely to do this in the near future. You might want to try .to_dask().map(...) to get futures out.

Contributions are welcome if you're willing to help out.

[kszucs]

Is it basicly just a client.compute() instead of `client.submit()?

What whould be the proper interface? Just map a delayed function on a Stream or stream.to_dask().map(delayed(func))?

[mrocklin]

I suspect that stream.to_dask().map(func) may do what you want already. Func will be applied on a dask worker instead of locally.