Dask数据帧大于延迟数

有没有办法做到这一点,但阈值是一个延迟的数字?

import dask
import pandas as pd
import dask.dataframe as dd

threshold = 3

df = pd.DataFrame({'something': [1,2,3,4]})
ddf = dd.from_pandas(df, npartitions=2)

ddf[ddf['something'] >= threshold]

如果…怎么办 threshold 是:

threshold = dask.delayed(3)

它给了我:

TypeError('Truth of Delayed objects is not supported')

我想保持沉默 ddf 作为dask数据帧,而不是将其转换为熊猫数据帧。想知道是否有组合形式也具有延迟值。