从dask生成列表-获取值错误

import dask
import dask.bag as db

# 创建一个Dask Bag
data = db.from_sequence([1, 2, 3, 4, 5])

# 定义一个计算任务
@dask.delayed
def square(x):
    return x * x

# 应用计算任务
squared_data = data.map(square)

# 等待计算完成并获取结果
result = squared_data.compute()
print(result)

import dask
import dask.bag as db

# 创建一个Dask Bag
data = db.from_sequence([1, 2, 3, 4, 5])

# 定义一个计算任务
@dask.delayed
def square(x):
    return x * x

# 应用计算任务
squared_data = data.map(square)

# 确保至少有一个计算节点
if not squared_data._graph.size == 0:
    result = squared_data.compute()
    print(result)
else:
    print("No computation nodes defined")

import dask
import dask.bag as db

# 创建一个Dask Bag
data = db.from_sequence([1, 2, 3, 4, 5])

# 定义一个计算任务
@dask.delayed
def square(x):
    if x == 3:
        raise ValueError("Invalid value")
    return x * x

# 应用计算任务
squared_data = data.map(square)

try:
    result = squared_data.compute(scheduler='threads')
    print(result)
except dask.delayed.ComputeError as e:
    print(f"Compute error: {e}")