Leonardo Rocha
04/04/2022, 8:49 PM@task
def file_write(x):
print(x)
with open('test_result.txt', 'a') as f:
f.write(str(x))
return x
with Flow("priority_test", executor=LocalDaskExecutor()) as flow:
with dask.annotate(priority=-10):
written1 = file_write(2)
with dask.annotate(priority=0):
written2 = file_write(1)
with dask.annotate(priority=10):
written3 = file_write(0)
I expected it to write "012", but am consistently getting "201"Kevin Kho
04/04/2022, 8:55 PMZanie
04/04/2022, 9:45 PM