我正在使用 Dask Distributed 通過(guò)接口將函數(shù)提交到我的集群client.submit。如果集群不可用,我默認(rèn)為串行、非分布式執(zhí)行。我希望能夠從函數(shù)中確定它是作為分布式未來(lái)運(yùn)行還是作為正常函數(shù)運(yùn)行。例如,對(duì)于work下面的函數(shù),我想知道它是通過(guò)運(yùn)行client.submit(work)還是簡(jiǎn)單地作為運(yùn)行work()。def work(): if is_distributed(): # do stuff else: # do different stuff上面應(yīng)該is_distributed()是什么樣子?
使用 Dask 分布式,函數(shù)如何自省以了解它是作為分布式 future 還是作為“正常”函數(shù)運(yùn)行?
喵喵時(shí)光機(jī)
2023-09-02 16:41:58