I'm getting a RuntimeError when trying to log from a dask.delayed function using a logger handler with enqueue enabled.
Here's a minimal reproducible example
import sys, dask
from loguru import logger
logger.add(sys.stderr, enqueue=True)
@da…
---
## Would you like to know more?
Read the full article on the following website:
<https://stackoverflow.com/questions/73711615/loguru-error-when-using-dask-with-a-multiprocessing-scheduler>
I'm getting a
RuntimeError
when trying to log from adask.delayed
function using a logger handler withenqueue
enabled.Here's a minimal reproducible example