Я отправляю распределенную задачу dask с submit () и добавляю add_done_callback на будущее.В текущей реализации dask обратный вызов вызывается в отдельном потоке от того, где был сделан обратный вызов.Иногда в этом потоке может возникать исключение, и я хотел бы добавить это исключение в основной поток, который поместил этот обратный вызов.
Моим обходным решением является размещение всего кода в этом обратном вызове между попыткой / исключением ипросто распечатайте уведомление о возникновении проблемы.В идеале я хотел бы получить доступ ко всему исключению и выяснить, где возникла проблема.
Мои вопросы:
- Есть ли лучший способ решения этой проблемы?
- Практически или возможно ли выполнить готовый обратный вызов в главном потоке, который поместил его подобно тому, как ipyparallel обрабатывает это?
Спасибо!