Proper shutdown for dask.distributed
Dieses Issue hat noch niemand übernommen.
Bewertung
- Schwierigkeit
- 4/5
- Geschätzter Aufwand
- 3-5 Tage
- Anfängerfreundlichkeit
- 35/100
- Issue-Typ
- Bug
- Klarheit
- Muss geklärt werden
- Aktivitätsstatus
- Veraltet
- Tech-Stack
- python
- Bereich
- distributed-systems
Rechercherichtung
Beginne in ipyparallel/client/client.py bei stop_dask und vergleiche es mit become_dask; untersuche, wie der Executor und der Dask-Client nachverfolgt werden. Reproduziere die distributed.client-Warnung und überprüfe anschließend, dass der Shutdown-Pfad keine Warnung hinterlässt, wenn stop_dask aufgerufen wird.
Vom Indexierungsmodell aus dem Issue-Text verfasst.
Beschreibung
When using the stop_dask method of the ipyparallel.Client, the following warning message pops up.
distributed.client - WARNING - Client report stream closed to scheduler
However, if I run shutdown on the Dask client provided by become_dask, and then run stop_dask, the warning goes away.
Looking at the code in ipyparallel it is not obvious how it would handle calling shutdown as it does not know the Dask client in stop_dask. However it does seem shutdown needs to be called on the executor. How exactly should shutdown be done with dask.distributed?
- Vorherrschende Sprache
- Jupyter Notebook
- Sterne
- 2.6k
- Forks
- 1k
- PR-Merge-Kennzahlen
- Keine gemergten PRs in 30 T.
Entwicklungsumgebung
Erste Schritte
- Lesen Sie das ganze Issue und danach den Beitragsleitfaden des Projekts.
- Schreiben Sie ins Issue, dass Sie es übernehmen — das erspart doppelte Arbeit.
- Forken Sie das Repository und arbeiten Sie in einem Branch.
- Öffnen Sie einen Pull Request, der die Issue-Nummer nennt.
Mehr aus ipython/ipyparallel
-
Schwierigkeit 4/5 3-5 Tage Anfängerfreundlichkeit 48/100
ipython/ipyparallel#1029 · 9 Kommentare ·
-
Schwierigkeit 2/5 1-3 Stunden Anfängerfreundlichkeit 35/100
ipython/ipyparallel#984 ·
-
Schwierigkeit 4/5 3-5 Tage Anfängerfreundlichkeit 35/100
ipython/ipyparallel#937 · 4 Kommentare ·
-
question
Schwierigkeit 5/5 Über eine Woche Anfängerfreundlichkeit 25/100
ipython/ipyparallel#897 · 12 Kommentare ·
-
bug
Schwierigkeit 4/5 3-5 Tage Anfängerfreundlichkeit 35/100
ipython/ipyparallel#882 ·
Alle Issues in ipython/ipyparallel
Ähnliche Issues
-
check_program_status() ignores errors on ranks other than 0, and calls Abort() with errorcode 0Offen
Schwierigkeit 2/5 1-3 Stunden Anfängerfreundlichkeit 84/100
NCAR/WrfHydroForcing#132 ·
-
bug P2 reliability workers
Schwierigkeit 2/5 1-3 Stunden Anfängerfreundlichkeit 86/100
afreidah/s3-orchestrator#1563 ·
Maintainer antworten meist innerhalb von 1 Tag
-
Schwierigkeit 2/5 1-3 Stunden Anfängerfreundlichkeit 84/100
ergoplatform/ergo#2579 ·
Maintainer antworten meist innerhalb von 2 Tagen
-
Schwierigkeit 2/5 1-3 Stunden Anfängerfreundlichkeit 78/100
apache/incubator-seata#8263 ·
Maintainer antworten meist innerhalb von 1 Tag
-
Schwierigkeit 2/5 1-3 Stunden Anfängerfreundlichkeit 88/100
apache/incubator-seata-go#1201 ·
Maintainer antworten meist innerhalb von 1 Tag