dask

Stellen Sie sich vor, ich habe ein Raster mit 10 Arbeitern & amp; 40 Kerne summiert sich. Dies ist ein geteiltes Raster, also möchte ich es nicht vollständig mit meiner Arbeit sättigen. Ich habe 1000 Aufgaben zu erledigen, und ich möchte maximal...

Beim Ausführen des folgenden Codes hängt das Ergebnis von dask.dataframe.head () von npartitions ab: %Vor% Dies ergibt das folgende Ergebnis: %Vor% Wenn ich jedoch npartitions auf 1 oder 2 setze, bekomme ich das erwartete Ergebnis: %Vo...