Utility for printing executable Python code from a dask graph.
Usage:
from dask2py import dask2py
def inc(x):
return 1 + x
def add(x, y):
return x + y
dsk = {'a': 1, 'b': 2, 'c': (inc, 'a'), 'd': (add, 'b', 'c')}
print('\n'.join(dask2py(dsk, 'd')))
Output:
a = 1
b = 2
c = inc(a)
d = add(b, c)