dask-distributed

1熱度

1回答

由於特定於我的構建系統的原因，我當前不能運行dask-scheduler CLI - 我必須從代碼啓動調度程序（示例在dask.distributed文檔中提供）。是否還有一種方法可以爲調度程序啓動和自定義（即選擇端口）Web GUI？

0熱度

1回答

我的daskgroupby腳本失敗（Memory Error），所以我開始調試腳本。我正在一臺獨立電腦上運行。我已經更新在config.yaml文件logging與 logging: distributed: debug bokeh: debug tornado: info 我運行dask distributed example computation以下更新： from distributed

2熱度

1回答

DASK計算與子期貨

我希望提交一個DASK的任務，將做到以下幾點：使用dask.bag（def fakejob）計算圖表建立一個懶DASK圖表從1和保存它要實木複合地板（留下這部分，只是一個動機）我需要爲多個輸入做到這一點，所以我一直在嘗試使用dask.distributed的期貨功能。 from dask.distributed import Client client = Client(processe

1熱度

1回答

在dask分發線程池中的任務

我一直在閱讀有關在worker上運行的任務生成新進程的文檔。我碰到這個從here：然而，每個正在運行的任務佔用了一個單獨的線程，所以如果你啓動啓動其他任務很多任務則是可能的，如果你不小心死鎖系統。您可以撥打分裂出去的功能在任務中，我們將會從專門的線程池刪除本身到不與DASK工人中佔用一個插槽行政螺紋是什麼意思移動到行政線？所有插槽都具有相同的優先級還是類似的？管理線程有優先權嗎？舉一個具體的

2熱度

1回答

是什麼叫dask.distrubuted.Executor和dask.distributed.Client

我有一個關於從DASK文檔併發期貨要點問題之間的區別：https://gist.github.com/mrocklin/ef9ccd29a6ec5f4de84d6192be95042a 當我們實例化一個執行者，這是否意味着它實例一個調度程序呢？執行人的再版說 <Client: scheduler='tcp://127.0.0.1:60329' processes=4 cores=4> 那麼究竟是什

0熱度

1回答

使用Dask計算會導致執行掛起

這是一個後續問題，以回答我之前關於使用Dask計算到access one element in a large array的問題之一的可能答案。爲什麼使用Dask計算會導致執行掛起？這裏的工作代碼片段： #Suppose you created a scheduler at the ip address of 111.111.11.11:8786 from dask.distribute