https://prefect.io logo
Title
d

David Elliott

10/19/2022, 2:56 PM
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
prefect==2.6.1
prefect-dask==0.2.0.post1
k

Kalise Richmond

10/19/2022, 4:08 PM
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

David Elliott

10/19/2022, 4:16 PM
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?