Hey all, it seems the <allow_failure()> wrapper do...
# prefect-community
d
Hey all, it seems the allow_failure() wrapper doesn’t work with the
DaskTaskRunner()
😢 It can’t pickle the task futures, which is sadly blocking our migration to 2.0. Have tried this both in Dask locally and also on k8s. Any ideas? MRE in 🧵
👀 1
1
Untitled.py
Copy code
prefect==2.6.1
prefect-dask==0.2.0.post1
k
Hi @David Elliott, this looks like a bug in the prefect-dask repo. Could you please file a git issue with your detail findings?
d
OK thanks - have raised it here https://github.com/PrefectHQ/prefect-dask/issues/43 Let me know if there’s anything else I should add / do?