RuntimeError: Barrier task with key 'shuffle-barrier-379659673650beace1aa63b2956e7b58' does not exist. This may be caused by task fusion during graph generation. Please let us know that you ran into this by leaving a comment at distributed#7816.

dask / distributed

A distributed task scheduler for Dask

https://distributed.dask.org

BSD 3-Clause "New" or "Revised" License

1.57k stars 715 forks source link

RuntimeError: Barrier task with key 'shuffle-barrier-379659673650beace1aa63b2956e7b58' does not exist. This may be caused by task fusion during graph generation. Please let us know that you ran into this by leaving a comment at distributed#7816. #8720

Open wangjianqiao111 opened 2 months ago

wangjianqiao111 commented 2 months ago

Describe the issue:

Minimal Complete Verifiable Example:

# Put your MCVE code here

Anything else we need to know?:

Environment:

Dask version:
Python version:
Operating System:
Install method (conda, pip, source):

hendrikmakait commented 2 months ago

@wangjianqiao111, thanks for reporting that you ran into this error. We'd need some more information to act on this. Can you provide a minimal example (see https://matthewrocklin.com/minimal-bug-reports) that reproduces this issue?